This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9b1375520b6 Modify obvious errors in the doc.
add 440fa5757ea [FLINK-34268] Add a test to verify if restore test exists
for ExecNode
add 5cc49c4f944 [FLINK-34095] Move async calc restore test
No new revisions were added by this update.
Summary of changes:
.../planner/plan/utils/ExecNodeMetadataUtil.java | 6 +-
.../nodes/exec/stream/AsyncCalcRestoreTest.java | 2 +-
.../exec/stream/ChangelogNormalizeRestoreTest.java | 5 +-
.../exec/stream/GroupAggregateRestoreTest.java | 3 +-
.../IncrementalGroupAggregateRestoreTest.java | 5 +-
.../plan/nodes/exec/testutils/RestoreTestBase.java | 28 ++++-
.../exec/testutils/RestoreTestCompleteness.java | 138 +++++++++++++++++++++
.../plan/async-calc-complex.json | 0
.../async-calc-complex/savepoint/_metadata | Bin
.../plan/async-calc-condition.json | 0
.../async-calc-condition/savepoint/_metadata | Bin
.../plan/async-calc-failure-exception.json | 0
.../savepoint/_metadata | Bin
.../async-calc-nested/plan/async-calc-nested.json | 0
.../async-calc-nested/savepoint/_metadata | Bin
.../async-calc-simple/plan/async-calc-simple.json | 0
.../async-calc-simple/savepoint/_metadata | Bin
17 files changed, 180 insertions(+), 7 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-complex/plan/async-calc-complex.json
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-complex/savepoint/_metadata (100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=>
stream-exec-async-calc_1}/async-calc-condition/plan/async-calc-condition.json
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-condition/savepoint/_metadata (100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=>
stream-exec-async-calc_1}/async-calc-failure-exception/plan/async-calc-failure-exception.json
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-failure-exception/savepoint/_metadata
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-nested/plan/async-calc-nested.json
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-nested/savepoint/_metadata (100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-simple/plan/async-calc-simple.json
(100%)
rename
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-calc_1
=> stream-exec-async-calc_1}/async-calc-simple/savepoint/_metadata (100%)
