feldera · mihaibudiu · May 12, 2026 · May 7, 2026 · May 10, 2026 · May 10, 2026
diff --git a/.github/workflows/test-java.yml b/.github/workflows/test-java.yml
@@ -62,13 +62,13 @@ jobs:
         run: gradle --stop
 
       - name: Run mvn test
-        run: mvn test --no-transfer-progress -q -B -pl SQL-compiler -Dsurefire.failIfNoSpecifiedTests=false
+        run: mvn test --no-transfer-progress -B -pl SQL-compiler -Dsurefire.failIfNoSpecifiedTests=false
         working-directory: ./sql-to-dbsp-compiler
         if: ${{ vars.CI_DRY_RUN != 'true' }}
 
       - name: Run one quick SLT test
         if: ${{ vars.CI_DRY_RUN != 'true' }}
-        run: mvn test --no-transfer-progress -q -B -Dsurefire.failIfNoSpecifiedTests=false -Dtest=RotateTests#quick
+        run: mvn test --no-transfer-progress -B -Dsurefire.failIfNoSpecifiedTests=false -Dtest=RotateTests#quick
         working-directory: ./sql-to-dbsp-compiler
 
       - name: Print sccache stats

diff --git a/crates/adapters/src/integrated.rs b/crates/adapters/src/integrated.rs
@@ -36,7 +36,7 @@ where
 }
 
 /// Create an instance of an integrated output endpoint given its config
-/// and output relation schema.p
+/// and output relation schema.
 #[allow(unused)]
 pub fn create_integrated_output_endpoint(
     endpoint_id: EndpointId,

diff --git a/crates/sqllib/src/source.rs b/crates/sqllib/src/source.rs
@@ -69,7 +69,7 @@ impl fmt::Display for SourcePositionRange {
 
 /// Maps "keys" to source line position information
 #[doc(hidden)]
-#[derive(Default)]
+#[derive(Debug, Default)]
 pub struct SourceMap {
     map: BTreeMap<(&'static str, u32), SourcePosition>,
 }

diff --git a/docs.feldera.com/docs/connectors/sources/debezium.md b/docs.feldera.com/docs/connectors/sources/debezium.md
@@ -194,7 +194,7 @@ CREATE TABLE my_table (
 )
 ```
 
-::: warning
+:::warning
 
 Notice that the data format provided by the connector contains data
 and metadata columns; for example, a metadata column is the "operation", which

diff --git a/docs.feldera.com/docs/connectors/unique_keys.md b/docs.feldera.com/docs/connectors/unique_keys.md
@@ -19,7 +19,7 @@ sources and data delivery to external sinks in two key ways:
  from tables *without* primary keys. Deleting a non-existent record for
  such tables will produce unexpected results or even pipeline crashes.
 
-::: danger
+:::danger
 
 Deleting records that do not exist from a table without a primary key is
 an undefined operation, and can produce incorrect results or crashes.

diff --git a/docs.feldera.com/docs/sql/grammar.md b/docs.feldera.com/docs/sql/grammar.md
@@ -347,7 +347,7 @@ values
   :   { VALUES | VALUE } expression [, expression ]*
 
 select
-  :   SELECT [ ALL | DISTINCT ]
+  :   SELECT [ hintComment ] [ ALL | DISTINCT ]
           { projectItem [, projectItem ]* }
       FROM tableExpression
       [ WHERE booleanExpression ]
@@ -360,7 +360,7 @@ select
 ```
 tablePrimary
   :   tableName '(' TABLE tableName ')'
-  |   tablePrimary '(' columnDecl [, columnDecl ]* ')'
+  |   tablePrimary [ hintComment ] '(' columnDecl [, columnDecl ]* ')'
   |   [ LATERAL ] '(' query ')'
   |   UNNEST '(' expression ')' [ WITH ORDINALITY ]
   |   TABLE '(' functionName '(' expression [, expression ]* ')' ')'
@@ -442,6 +442,67 @@ the column names are *not* used to reorder columns.
 In `orderItem`, if expression is a positive integer n, it denotes the
 nth item in the `SELECT` clause.
 
+## SQL hints
+
+A hint is an instruction to the optimizer.  When writing SQL, you may
+know information about the data unknown to the optimizer.  Hints
+enable you to make decisions normally made by the optimizer.
+
+We support hints in two locations:
+
+- Query Hint: right after the `SELECT` keyword;
+- Table Hint: right after the referenced table or view name.
+
+```
+SELECT /*+ broadcast(S), shard(T) */
+FROM
+  T /*+ size(5) */
+JOIN
+  S
+```
+
+The syntax of hints is:
+
+```
+hintComment
+  :   '/*+' hint [, hint ]* '*/'
+
+hint:
+      hintName
+  |   hintName '(' optionKey '=' optionVal [, optionKey '=' optionVal ]* ')'
+  |   hintName '(' hintOption [, hintOption ]* ')'
+
+optionKey
+  :   simpleIdentifier
+  |   stringLiteral
+
+optionVal
+  :   simpleIdentifier
+  |   stringLiteral
+
+hintOption
+   :  simpleIdentifier
+   |  numericLiteral
+   |  stringLiteral
+```
+
+### Supported hints and their impact on query implementation
+
+:::warning
+
+These hints are considered still experimental, and they may change
+
+:::
+
+- `broadcast(`*table*`)`: Indicates that the following `JOIN` should be implemented using
+  a broadcast-join strategy by broadcasting the input with alias *table*
+- `shard(`*table*`)`: Indicates that the following `JOIN` should be implemented using
+  a hash-join strategy by sharding the input with alias *table*
+- `balance(`*table*`)`: Indicates that the following `JOIN` should be implemented using
+  a balanced strategy by hashing on all fields the input with alias *table*
+
+Note: specifying hints may inhibit some compiler optimizations.
+
 ## Creating indexes
 
 Feldera supports the `CREATE INDEX` SQL statement with the following

diff --git a/docs.feldera.com/docs/sql/identifiers.md b/docs.feldera.com/docs/sql/identifiers.md
@@ -107,7 +107,7 @@ GROUP BY x+1
 HAVING x+1 > 0;
 ```
 
-::: danger
+:::danger
 
 In order to preserve the semantics of standard SQL programs unchanged,
 a new column alias is used only if there is no column with the same

diff --git a/js-packages/profiler-lib/src/profile.ts b/js-packages/profiler-lib/src/profile.ts
@@ -26,7 +26,7 @@ interface JsonMetricBase {
 interface MetricValue { };
 
 // Base types
-interface PersistentIdMetricValue extends MetricValue {
+interface StringMetricValue extends MetricValue {
     type: "string";
     value: string;
 }
@@ -54,6 +54,11 @@ interface BytesMetricValue {
     value: number;
 }
 
+interface BoolMetricValue {
+    type: "bool";
+    value: boolean;
+}
+
 interface PercentMetricValue {
     type: "percent";
     value: {
@@ -110,12 +115,13 @@ interface CacheStatsValue extends MetricValue {
 }
 
 type JsonMetricValue =
+    BoolMetricValue |
     CountMetricValue |
     BytesMetricValue |
     PercentMetricValue |
     DurationMetricValue |
     StatsMetricValue |
-    PersistentIdMetricValue |
+    StringMetricValue |
     DistributionValue |
     RetainmentValue |
     IntMetricValue |
@@ -375,6 +381,10 @@ class BooleanValue extends PropertyValue {
         this.value = id;
     }
 
+    static fromBoolMetric(value: BoolMetricValue): BooleanValue {
+        return new BooleanValue(value.value);
+    }
+
     getNumericValue(): Option<number> {
         return this.value ? Option.some(0) : Option.some(1);
     }
@@ -721,12 +731,17 @@ export class Measurement {
         let metric_id = metric.metric_id;
         let kind = metric_id.split("_").pop(); // count, bytes, etc
         if (metric.labels) {
-           let labels = metric.labels.map(e => e.join(":")).join(".");
-           if (metric.labels.length !== 0) {
-               metric_id = metric_id + "." + labels;
-           }
+            let labels = metric.labels.map(e => e.join(":")).join(".");
+            if (metric.labels.length !== 0) {
+                metric_id = metric_id + "." + labels;
+            }
         }
         switch (kind) {
+            case "bool": {
+                let m = metric.value as BoolMetricValue;
+                let value = BooleanValue.fromBoolMetric(m);
+                return [new Measurement(metric_id, Option.some(value))];
+            }
             case "bytes": {
                 let m = metric.value as BytesMetricValue;
                 let bytes = BytesValue.fromBytesMetric(m);
@@ -767,7 +782,7 @@ export class Measurement {
                 ];
             }
             case "id": { // persistent_id
-                let s = metric.value as PersistentIdMetricValue;
+                let s = metric.value as StringMetricValue;
                 let str = StringValue.fromString(s.value);
                 return [new Measurement(metric_id, Option.some(str))];
             }
@@ -845,6 +860,11 @@ export class Measurement {
                     new Measurement(metric_id + ".steps", Option.some(steps)),
                 ];
             }
+            case "policy": {
+                let s = metric.value as StringMetricValue;
+                let str = StringValue.fromString(s.value);
+                return [new Measurement(metric_id, Option.some(str))];
+            }
         }
         return [];
     }

diff --git a/python/tests/runtime_aggtest/arithmetic_tests/test_date.py b/python/tests/runtime_aggtest/arithmetic_tests/test_date.py
@@ -335,7 +335,7 @@ def __init__(self):
                 "ytm_str": "+10-01",
                 "dth_str": "+3683 00",
                 "dtm_str": "+3683 00:00",
-                "dts_str": "+3683 00:00:00.000000",
+                "dts_str": "+3683 00:00:00",
                 "htm_str": "+88392:00",
                 "hts_str": "+88392:00:00.000000",
                 "mts_str": "+5303520:00.000000",
@@ -345,7 +345,7 @@ def __init__(self):
                 "ytm_str": "-2-08",
                 "dth_str": "-980 00",
                 "dtm_str": "-980 00:00",
-                "dts_str": "-980 00:00:00.000000",
+                "dts_str": "-980 00:00:00",
                 "htm_str": "-23520:00",
                 "hts_str": "-23520:00:00.000000",
                 "mts_str": "-1411200:00.000000",
@@ -355,7 +355,7 @@ def __init__(self):
                 "ytm_str": "+20-06",
                 "dth_str": "+7506 00",
                 "dtm_str": "+7506 00:00",
-                "dts_str": "+7506 00:00:00.000000",
+                "dts_str": "+7506 00:00:00",
                 "htm_str": "+180144:00",
                 "hts_str": "+180144:00:00.000000",
                 "mts_str": "+10808640:00.000000",
@@ -646,7 +646,7 @@ def __init__(self):
                 "ytm_neg": "-10-01",
                 "dth_neg": "-3683 00",
                 "dtm_neg": "-3683 00:00",
-                "dts_neg": "-3683 00:00:00.000000",
+                "dts_neg": "-3683 00:00:00",
                 "htm_neg": "-88392:00",
                 "hts_neg": "-88392:00:00.000000",
                 "mts_neg": "-5303520:00.000000",
@@ -656,7 +656,7 @@ def __init__(self):
                 "ytm_neg": "+2-08",
                 "dth_neg": "+980 00",
                 "dtm_neg": "+980 00:00",
-                "dts_neg": "+980 00:00:00.000000",
+                "dts_neg": "+980 00:00:00",
                 "htm_neg": "+23520:00",
                 "hts_neg": "+23520:00:00.000000",
                 "mts_neg": "+1411200:00.000000",
@@ -666,7 +666,7 @@ def __init__(self):
                 "ytm_neg": "-20-06",
                 "dth_neg": "-7506 00",
                 "dtm_neg": "-7506 00:00",
-                "dts_neg": "-7506 00:00:00.000000",
+                "dts_neg": "-7506 00:00:00",
                 "htm_neg": "-180144:00",
                 "hts_neg": "-180144:00:00.000000",
                 "mts_neg": "-10808640:00.000000",