diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java
index a16f63b18e425..ba92e8894ab53 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java
+++ b/flink-table/flink-table-planner/src/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)