This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8a45cd6cffb [FLINK-35941][table-planner] Add CompiledPlan annotations
to BatchExecLimit
add f1eb644024d [FLINK-35944] Add CompiledPlan annotations to
BatchExecUnion
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/batch/BatchExecHashAggregate.java | 70 +++++++++++++++-
.../plan/nodes/exec/batch/BatchExecUnion.java | 21 +++++
.../planner/plan/utils/ExecNodeMetadataUtil.java | 4 +
.../UnionBatchRestoreTest.java} | 13 +--
.../exec/{stream => common}/UnionTestPrograms.java | 8 +-
.../plan/nodes/exec/stream/UnionRestoreTest.java | 1 +
.../plan/union-all-two-sources.json | 40 +++++-----
.../plan/union-all-with-filter.json | 56 +++++++------
.../union-two-sources/plan/union-two-sources.json | 92 ++++++++++++++--------
9 files changed, 212 insertions(+), 93 deletions(-)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/{stream/UnionRestoreTest.java
=> batch/UnionBatchRestoreTest.java} (77%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/{stream
=> common}/UnionTestPrograms.java (97%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-union_1
=> batch-exec-union_1}/union-all-two-sources/plan/union-all-two-sources.json
(84%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-union_1
=> batch-exec-union_1}/union-all-with-filter/plan/union-all-with-filter.json
(86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-union_1
=> batch-exec-union_1}/union-two-sources/plan/union-two-sources.json (67%)
