This is an automated email from the ASF dual-hosted git repository.
wanglijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6c9bb3716a3 [FLINK-32945][runtime] Fix NPE when task reached
end-of-data but checkpoint failed
add 5ce5c8142c8 [FlINK-32865][table-planner] Add ExecutionOrderEnforcer to
exec plan and put it into BatchExecMultipleInput
add 3fffed00df3 [FlINK-32865][table-planner] Make ExecutionOrderEnforcer
support OFCG
No new revisions were added by this update.
Summary of changes:
.../planner/plan/nodes/exec/ExecNodeBase.java | 4 -
...r.java => BatchExecExecutionOrderEnforcer.java} | 128 +++++++-----
.../nodes/exec/batch/BatchExecMultipleInput.java | 18 --
.../nodes/exec/batch/BatchExecTableSourceScan.java | 69 ++-----
.../DynamicFilteringDependencyProcessor.java | 111 ++++++++---
.../processor/ResetTransformationProcessor.java | 46 -----
.../ExecutionOrderEnforcerCodeGenerator.scala | 57 ++++++
.../table/planner/delegation/BatchPlanner.scala | 9 +-
.../ExecutionOrderEnforcerFusionCodegenSpec.scala | 78 ++++++++
.../ResetTransformationProcessorTest.java | 143 --------------
.../runtime/batch/sql/DynamicFilteringITCase.java | 54 ++++--
.../plan/batch/sql/DynamicFilteringTest.xml | 214 +++++++++++----------
.../nodes/exec/operator/BatchOperatorNameTest.xml | 16 +-
.../program/DynamicPartitionPruningProgramTest.xml | 18 +-
.../program/FlinkRuntimeFilterProgramTest.xml | 8 +-
.../ExecutionOrderEnforcerOperator.java | 71 -------
.../ExecutionOrderEnforcerOperatorFactory.java | 47 -----
17 files changed, 494 insertions(+), 597 deletions(-)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/{runtimefilter/BatchExecRuntimeFilter.java
=> BatchExecExecutionOrderEnforcer.java} (53%)
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/ResetTransformationProcessor.java
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/dynamicfiltering/ExecutionOrderEnforcerCodeGenerator.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/fusion/spec/ExecutionOrderEnforcerFusionCodegenSpec.scala
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/processor/ResetTransformationProcessorTest.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/ExecutionOrderEnforcerOperator.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/ExecutionOrderEnforcerOperatorFactory.java
