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