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
