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 360abe667a6 [FLINK-33752][Configuration] Change the displayed timeunit
to day when the duration is an integral multiple of 1 day
new 2c7f2d4bca2 [FLINK-33470] Implement restore tests for Join node
new 78b0a625f49 [FLINK-33470] Deleting JoinJsonPlanTest.java and
JoinJsonPlanITCase.java
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/table/test/program/SinkTestStep.java | 24 +-
.../factories/TestValuesRuntimeFunctions.java | 10 +-
.../plan/nodes/exec/stream/JoinJsonPlanTest.java | 144 -------
.../plan/nodes/exec/testutils/JoinRestoreTest.java | 51 +++
.../nodes/exec/testutils/JoinTestPrograms.java | 452 +++++++++++++++++++++
.../plan/nodes/exec/testutils/RestoreTestBase.java | 28 +-
.../stream/jsonplan/JoinJsonPlanITCase.java | 168 --------
.../join-anti-join/plan/join-anti-join.json} | 189 ++++-----
.../join-anti-join/savepoint/_metadata | Bin 0 -> 9809 bytes
.../join-cross-join/plan/join-cross-join.json} | 129 +++---
.../join-cross-join/savepoint/_metadata | Bin 0 -> 12160 bytes
.../plan/join-inner-join-with-duplicate-key.json} | 156 +++----
.../savepoint/_metadata | Bin 0 -> 12351 bytes
.../plan/join-inner-join-with-equal-pk.json} | 150 ++++---
.../savepoint/_metadata | Bin 0 -> 18604 bytes
.../plan/join-inner-join-with-non-equi-join.json} | 147 +++----
.../savepoint/_metadata | Bin 0 -> 13379 bytes
.../plan/join-inner-join-with-pk.json} | 198 ++++-----
.../join-inner-join-with-pk/savepoint/_metadata | Bin 0 -> 21978 bytes
.../join-left-join/plan/join-left-join.json} | 152 +++----
.../join-left-join/savepoint/_metadata | Bin 0 -> 13348 bytes
.../join-non-window-inner-join-with-null-cond.json | 354 ++++++++++++++++
.../savepoint/_metadata | Bin 0 -> 15297 bytes
.../plan/join-non-window-inner-join.json | 354 ++++++++++++++++
.../join-non-window-inner-join/savepoint/_metadata | Bin 0 -> 15205 bytes
.../join-outer-join/plan/join-outer-join.json} | 154 +++----
.../join-outer-join/savepoint/_metadata | Bin 0 -> 13689 bytes
.../join-right-join/plan/join-right-join.json} | 154 +++----
.../join-right-join/savepoint/_metadata | Bin 0 -> 13096 bytes
.../join-semi-join/plan/join-semi-join.json} | 141 ++++---
.../join-semi-join/savepoint/_metadata | Bin 0 -> 11260 bytes
.../join-with-filter/plan/join-with-filter.json | 305 ++++++++++++++
.../join-with-filter/savepoint/_metadata | Bin 0 -> 12143 bytes
33 files changed, 2284 insertions(+), 1176 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinRestoreTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/JoinJsonPlanITCase.java
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=> restore-tests/stream-exec-join_1/join-anti-join/plan/join-anti-join.json}
(54%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-anti-join/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out
=> restore-tests/stream-exec-join_1/join-cross-join/plan/join-cross-join.json}
(60%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-cross-join/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=>
restore-tests/stream-exec-join_1/join-inner-join-with-duplicate-key/plan/join-inner-join-with-duplicate-key.json}
(57%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-with-duplicate-key/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithEqualPk.out
=>
restore-tests/stream-exec-join_1/join-inner-join-with-equal-pk/plan/join-inner-join-with-equal-pk.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-with-equal-pk/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=>
restore-tests/stream-exec-join_1/join-inner-join-with-non-equi-join/plan/join-inner-join-with-non-equi-join.json}
(59%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-with-non-equi-join/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithPk.out
=>
restore-tests/stream-exec-join_1/join-inner-join-with-pk/plan/join-inner-join-with-pk.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-with-pk/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=> restore-tests/stream-exec-join_1/join-left-join/plan/join-left-join.json}
(58%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-left-join/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-non-window-inner-join-with-null-cond/plan/join-non-window-inner-join-with-null-cond.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-non-window-inner-join-with-null-cond/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-non-window-inner-join/plan/join-non-window-inner-join.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-non-window-inner-join/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=> restore-tests/stream-exec-join_1/join-outer-join/plan/join-outer-join.json}
(58%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-outer-join/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
=> restore-tests/stream-exec-join_1/join-right-join/plan/join-right-join.json}
(58%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-right-join/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out
=> restore-tests/stream-exec-join_1/join-semi-join/plan/join-semi-join.json}
(58%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-semi-join/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-with-filter/plan/join-with-filter.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-with-filter/savepoint/_metadata
