[hotfix][table-planner-blink] FlinkStreamProgram should not use Flink…

…BatchRuleSets (apache#13100)
spotify · Aug 10, 2020 · 6ef7d79 · 6ef7d79
1 parent b8d2ed7
commit 6ef7d79
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala b/.../main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala
@@ -21,7 +21,7 @@ package org.apache.flink.table.planner.plan.optimize.program
 import org.apache.flink.configuration.Configuration
 import org.apache.flink.table.api.config.OptimizerConfigOptions
 import org.apache.flink.table.planner.plan.nodes.FlinkConventions
-import org.apache.flink.table.planner.plan.rules.{FlinkBatchRuleSets, FlinkStreamRuleSets}
+import org.apache.flink.table.planner.plan.rules.FlinkStreamRuleSets
 
 import org.apache.calcite.plan.hep.HepMatchOrder
 
@@ -122,7 +122,7 @@ object FlinkStreamProgram {
  FlinkHepRuleSetProgramBuilder.newBuilder
  .setHepRulesExecutionType(HEP_RULES_EXECUTION_TYPE.RULE_SEQUENCE)
  .setHepMatchOrder(HepMatchOrder.BOTTOM_UP)
- .add(FlinkBatchRuleSets.FILTER_TABLESCAN_PUSHDOWN_RULES)
+ .add(FlinkStreamRuleSets.FILTER_TABLESCAN_PUSHDOWN_RULES)
  .build(), "push predicate into table scan")
  .addProgram(
  FlinkHepRuleSetProgramBuilder.newBuilder