This is an automated email from the ASF dual-hosted git repository.
fhueske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 98ab58c023e [FLINK-39522] Defer task finish until recovery completes
new 34bda761e9c [FLINK-39785][table] Honor source.sleep-* in TestValues
watermark-push-down source
new c6fc527d1e0 [FLINK-39785][table] Add input-driven savepoint trigger to
restore test framework
new a77d210c996 [FLINK-39785][table] Add LATERAL SNAPSHOT e2e and restore
tests
The 3 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:
.../factories/TestValuesRuntimeFunctions.java | 80 +++-
.../planner/factories/TestValuesTableFactory.java | 35 +-
.../stream/LateralSnapshotJoinRestoreTest.java | 67 ++++
.../LateralSnapshotJoinSemanticTestPrograms.java | 439 +++++++++++++++++++++
....java => LateralSnapshotJoinSemanticTests.java} | 25 +-
.../stream/LateralSnapshotJoinTestPrograms.java | 176 +++++++++
.../exec/testutils/CommonSemanticTestBase.java | 2 +
.../plan/nodes/exec/testutils/RestoreTestBase.java | 50 ++-
.../exec/testutils/RestoreTestCompleteness.java | 6 -
.../stream/sql/join/LateralSnapshotJoinITCase.java | 290 ++++++++++++++
.../plan/lateral-snapshot-join-inner.json} | 365 ++++++++++-------
.../savepoint/_metadata | Bin 0 -> 19149 bytes
.../plan/lateral-snapshot-join-load-phase.json} | 364 ++++++++++-------
.../savepoint/_metadata | Bin 0 -> 18950 bytes
14 files changed, 1565 insertions(+), 334 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LateralSnapshotJoinRestoreTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LateralSnapshotJoinSemanticTestPrograms.java
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{ChangelogNormalizeSemanticTests.java
=> LateralSnapshotJoinSemanticTests.java} (55%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LateralSnapshotJoinTestPrograms.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/LateralSnapshotJoinITCase.java
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/stream/sql/join/LateralSnapshotJoinTest_jsonplan/testInnerJoinWithNonEquiConditionJsonPlan.out
=>
restore-tests/stream-exec-lateral-snapshot-join_1/lateral-snapshot-join-inner/plan/lateral-snapshot-join-inner.json}
(50%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lateral-snapshot-join_1/lateral-snapshot-join-inner/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/stream/sql/join/LateralSnapshotJoinTest_jsonplan/testInnerJoinWithNonEquiConditionJsonPlan.out
=>
restore-tests/stream-exec-lateral-snapshot-join_1/lateral-snapshot-join-load-phase/plan/lateral-snapshot-join-load-phase.json}
(50%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lateral-snapshot-join_1/lateral-snapshot-join-load-phase/savepoint/_metadata
