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 907d0f32126 [FLINK-33881][state] Avoid copy and update value in
TtlListState#getUnexpiredOrNull
add d6209a18bbc [FLINK-33969] Implement restore tests for TableSourceScan
node
add e98ded88876 [FLINK-33969] Remove TableSource Json Plan & Json IT tests
No new revisions were added by this update.
Summary of changes:
.../table/test/program/StatementSetTestStep.java | 16 +-
.../flink/table/test/program/TableTestProgram.java | 15 ++
.../nodes/exec/stream/TableSourceJsonPlanTest.java | 198 ----------------
.../exec/stream/TableSourceScanRestoreTest.java | 47 ++++
.../exec/stream/TableSourceScanTestPrograms.java | 263 +++++++++++++++++++++
.../plan/nodes/exec/testutils/RestoreTestBase.java | 13 +-
.../stream/jsonplan/TableSourceJsonPlanITCase.java | 180 --------------
.../testWatermarkPushDown.out | 190 ---------------
.../plan/table-source-scan-filter-pushdown.json} | 49 ++--
.../savepoint/_metadata | Bin 0 -> 8291 bytes
.../plan/table-source-scan-limit-pushdown.json} | 66 +++---
.../savepoint/_metadata | Bin 0 -> 11254 bytes
.../plan/table-source-scan-multiple-pushdowns.json | 204 ++++++++++++++++
.../savepoint/_metadata | Bin 0 -> 5409 bytes
.../table-source-scan-partition-pushdown.json} | 77 +++---
.../savepoint/_metadata | Bin 0 -> 8342 bytes
...le-source-scan-project-push-down-disabled.json} | 87 ++++---
.../savepoint/_metadata | Bin 0 -> 7260 bytes
.../plan/table-source-scan-project-pushdown.json} | 42 ++--
.../savepoint/_metadata | Bin 0 -> 7207 bytes
.../plan/table-source-scan-reading-metadata.json} | 53 ++---
.../savepoint/_metadata | Bin 0 -> 9287 bytes
.../plan/table-source-scan-reuse-source.json} | 128 ++++++----
.../savepoint/_metadata | Bin 0 -> 13123 bytes
.../plan/table-source-scan-source-watermark.json} | 93 ++++----
.../savepoint/_metadata | Bin 0 -> 6794 bytes
26 files changed, 851 insertions(+), 870 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceScanRestoreTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceScanTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/TableSourceJsonPlanITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testFilterPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-filter-pushdown/plan/table-source-scan-filter-pushdown.json}
(72%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-filter-pushdown/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testLimitPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-limit-pushdown/plan/table-source-scan-limit-pushdown.json}
(74%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-limit-pushdown/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-multiple-pushdowns/plan/table-source-scan-multiple-pushdowns.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-multiple-pushdowns/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-partition-pushdown/plan/table-source-scan-partition-pushdown.json}
(67%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-partition-pushdown/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-project-push-down-disabled/plan/table-source-scan-project-push-down-disabled.json}
(57%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-project-push-down-disabled/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-project-pushdown/plan/table-source-scan-project-pushdown.json}
(70%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-project-pushdown/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-reading-metadata/plan/table-source-scan-reading-metadata.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-reading-metadata/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReuseSourceWithoutProjectionPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-reuse-source/plan/table-source-scan-reuse-source.json}
(53%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-reuse-source/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out
=>
restore-tests/stream-exec-table-source-scan_1/table-source-scan-source-watermark/plan/table-source-scan-source-watermark.json}
(57%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-table-source-scan_1/table-source-scan-source-watermark/savepoint/_metadata
