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 d4a3687aacd [FLIP-321] Update the docs to add migration periods for
deprecated APIs. (#23865)
new 46d817d8d29 [FLINK-33767] Implement restore tests for TemporalJoin node
new 20a328d80a1 [FLINK-33767] Deleting TemporalJoinJsonPlanTest.java and
TemporalJoinJsonPlanITCase.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/TableTestProgram.java | 22 ++
...TestStep.java => TemporalFunctionTestStep.java} | 44 ++--
.../apache/flink/table/test/program/TestStep.java | 1 +
.../exec/stream/TemporalJoinJsonPlanTest.java | 101 ---------
...storeTest.java => TemporalJoinRestoreTest.java} | 12 +-
.../exec/stream/TemporalJoinTestPrograms.java | 103 +++++++++
.../plan/nodes/exec/testutils/RestoreTestBase.java | 3 +
.../jsonplan/TemporalJoinJsonPlanITCase.java | 107 ----------
.../plan/temporal-join-table-join.json} | 213 +++++++++++++------
.../temporal-join-table-join/savepoint/_metadata | Bin 0 -> 14926 bytes
.../plan/temporal-join-temporal-function.json} | 235 ++++++++++++++-------
.../savepoint/_metadata | Bin 0 -> 14926 bytes
12 files changed, 450 insertions(+), 391 deletions(-)
copy
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/{FunctionTestStep.java
=> TemporalFunctionTestStep.java} (58%)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest.java
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{TemporalSortRestoreTest.java
=> TemporalJoinRestoreTest.java} (77%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/TemporalJoinJsonPlanITCase.java
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testTemporalTableJoin.out
=>
restore-tests/stream-exec-temporal-join_1/temporal-join-table-join/plan/temporal-join-table-join.json}
(69%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-temporal-join_1/temporal-join-table-join/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testJoinTemporalFunction.out
=>
restore-tests/stream-exec-temporal-join_1/temporal-join-temporal-function/plan/temporal-join-temporal-function.json}
(66%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-temporal-join_1/temporal-join-temporal-function/savepoint/_metadata
