fix

snuyanzin · Mar 15, 2024 · cc8726d · cc8726d
1 parent fae1ba5
commit cc8726d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java b/.../main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java
@@ -20,6 +20,7 @@
 
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.table.planner.calcite.FlinkRelBuilder;
+import org.apache.flink.table.planner.calcite.FlinkRelFactories;
 import org.apache.flink.table.runtime.operators.rank.ConstantRankRange;
 import org.apache.flink.table.runtime.operators.rank.RankType;
 
@@ -210,6 +211,7 @@ public interface CorrelateSortToRankRuleConfig extends RelRule.Config {
         CorrelateSortToRankRule.CorrelateSortToRankRuleConfig DEFAULT =
                 ImmutableCorrelateSortToRankRule.CorrelateSortToRankRuleConfig.builder()
                         .build()
+                        .withRelBuilderFactory(FlinkRelFactories.FLINK_REL_BUILDER())
                         .withOperandSupplier(
                                 b0 ->
                                         b0.operand(Correlate.class)