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 59c42d96062 [FLINK-25857] Add committer metrics to track the status of committables new 7e4a2f3fe6c [FLINK-33647] Implement restore tests for LookupJoin node new c49ab9ae429 [FLINK-33647] Remove LookupJoin JsonPlan & JsonIT tests 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: .../nodes/exec/stream/LookupJoinJsonPlanTest.java | 273 ----------- .../nodes/exec/stream/LookupJoinRestoreTest.java | 46 ++ .../nodes/exec/stream/LookupJoinTestPrograms.java | 388 +++++++++++++++ .../plan/nodes/exec/testutils/RestoreTestBase.java | 3 - .../stream/jsonplan/LookupJoinJsonPlanITCase.java | 113 ----- .../testAggAndLeftJoinWithTryResolveMode.out | 465 ------------------ .../testJoinTemporalTable.out | 477 ------------------- .../testJoinTemporalTableWithAsyncHint.out | 477 ------------------- .../testJoinTemporalTableWithAsyncHint2.out | 477 ------------------- .../testJoinTemporalTableWithAsyncRetryHint.out | 483 ------------------- .../testJoinTemporalTableWithAsyncRetryHint2.out | 483 ------------------- ...testJoinTemporalTableWithProjectionPushDown.out | 466 ------------------ .../testJoinTemporalTableWithRetryHint.out | 483 ------------------- ...eftJoinTemporalTableWithMultiJoinConditions.out | 526 --------------------- .../testLeftJoinTemporalTableWithPostFilter.out | 501 -------------------- .../testLeftJoinTemporalTableWithPreFilter.out | 492 ------------------- .../plan/lookup-join-async-hint.json | 251 ++++++++++ .../lookup-join-async-hint/savepoint/_metadata | Bin 0 -> 15900 bytes .../plan/lookup-join-filter-pushdown.json | 264 +++++++++++ .../savepoint/_metadata | Bin 0 -> 13735 bytes .../plan/lookup-join-left-join.json | 279 +++++++++++ .../lookup-join-left-join/savepoint/_metadata | Bin 0 -> 14069 bytes .../plan/lookup-join-post-filter.json | 266 +++++++++++ .../lookup-join-post-filter/savepoint/_metadata | Bin 0 -> 14021 bytes .../plan/lookup-join-pre-filter.json | 279 +++++++++++ .../lookup-join-pre-filter/savepoint/_metadata | Bin 0 -> 14005 bytes .../plan/lookup-join-pre-post-filter.json | 281 +++++++++++ .../savepoint/_metadata | Bin 0 -> 13957 bytes .../plan/lookup-join-project-pushdown.json | 248 ++++++++++ .../savepoint/_metadata | Bin 0 -> 13139 bytes .../plan/lookup-join-retry-hint.json | 252 ++++++++++ .../lookup-join-retry-hint/savepoint/_metadata | Bin 0 -> 14135 bytes 32 files changed, 2554 insertions(+), 5719 deletions(-) delete mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinRestoreTest.java create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinTestPrograms.java delete mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/LookupJoinJsonPlanITCase.java delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testAggAndLeftJoinWithTryResolveMode.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncHint.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncHint2.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncRetryHint.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncRetryHint2.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithRetryHint.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testLeftJoinTemporalTableWithMultiJoinConditions.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testLeftJoinTemporalTableWithPostFilter.out delete mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testLeftJoinTemporalTableWithPreFilter.out create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-async-hint/plan/lookup-join-async-hint.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-async-hint/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-filter-pushdown/plan/lookup-join-filter-pushdown.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-filter-pushdown/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-left-join/plan/lookup-join-left-join.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-left-join/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-post-filter/plan/lookup-join-post-filter.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-post-filter/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-pre-filter/plan/lookup-join-pre-filter.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-pre-filter/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-pre-post-filter/plan/lookup-join-pre-post-filter.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-pre-post-filter/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-project-pushdown/plan/lookup-join-project-pushdown.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-project-pushdown/savepoint/_metadata create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-retry-hint/plan/lookup-join-retry-hint.json create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-lookup-join_1/lookup-join-retry-hint/savepoint/_metadata