You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2025/06/08 17:04:16 UTC
(flink) branch master updated: [FLINK-37899][table] Stabilize JoinRestoreTest
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 680fea2894e [FLINK-37899][table] Stabilize JoinRestoreTest
680fea2894e is described below
commit 680fea2894e8116ba90ad1ab6a0ef05de2e34e00
Author: Sergey Nuyanzin <sn...@gmail.com>
AuthorDate: Sun Jun 8 19:04:09 2025 +0200
[FLINK-37899][table] Stabilize JoinRestoreTest
---
.../plan/nodes/exec/common/JoinTestPrograms.java | 19 +++++++++----------
.../savepoint/_metadata | Bin 44588 -> 45482 bytes
2 files changed, 9 insertions(+), 10 deletions(-)
diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinTestPrograms.java
index c1024565e0f..a6d3582964c 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinTestPrograms.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinTestPrograms.java
@@ -472,28 +472,27 @@ public class JoinTestPrograms {
.setupTableSource(
SourceTestStep.newBuilder("source_t1")
.addSchema("a INTEGER", "b BIGINT", "c STRING")
- .producedBeforeRestore(Row.of(1, 2L, "3"))
- .producedAfterRestore(Row.of(12, 34L, "56"))
+ .producedBeforeRestore(
+ Row.of(1, 2L, "3"), Row.of(12, 34L, "56"))
.build())
.setupTableSource(
SourceTestStep.newBuilder("source_t2")
.addSchema("d INTEGER", "e BIGINT", "f STRING")
- .producedBeforeRestore(Row.of(1, 2L, "3"))
- .producedAfterRestore(Row.of(11, 22L, "33"))
+ .producedBeforeRestore(
+ Row.of(1, 2L, "3"), Row.of(11, 22L, "33"))
.build())
.setupTableSource(
SourceTestStep.newBuilder("source_t3")
.addSchema("i INTEGER", "j BIGINT", "k STRING")
- .producedBeforeRestore(Row.of(1, 2L, "3"))
- .producedAfterRestore(Row.of(111, 222L, "333"))
+ .producedBeforeRestore(
+ Row.of(1, 2L, "3"), Row.of(111, 222L, "333"))
.build())
.setupTableSink(
SinkTestStep.newBuilder("sink_t")
.addSchema("b BIGINT")
- .consumedBeforeRestore("+I[2]")
- .consumedAfterRestore(
- "-D[2]", "+I[2]", "+I[34]", "-D[2]", "-D[34]",
- "+I[2]", "+I[34]")
+ .consumedBeforeRestore(
+ "+I[2]", "+I[34]", "-D[2]", "-D[34]", "+I[2]",
+ "+I[34]")
.build())
.runSql(
"INSERT INTO sink_t SELECT b FROM source_t1 WHERE"
diff --git a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/semi-anti-join-with-literal-agg/savepoint/_metadata b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/semi-anti-join-with-literal-agg/savepoint/_metadata
index ad0b6d005e4..9a24eab1bb5 100644
Binary files a/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/semi-anti-join-with-literal-agg/savepoint/_metadata and b/flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/semi-anti-join-with-literal-agg/savepoint/_metadata differ