From dbf2bdea62de1ac0cc981c746bd83390c044e84b Mon Sep 17 00:00:00 2001 From: Sergey Nuyanzin Date: Fri, 6 Jun 2025 15:25:02 +0200 Subject: [PATCH 1/2] [FLINK-37899][table] Stabilize JoinRestoreTest --- .../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 c1024565e0f5f..a6d3582964c56 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 ad0b6d005e472777b786fc7fba23447aadc83f3c..9a24eab1bb59fcf7da2e976d3ad4e7b8e28aeb4b 100644 GIT binary patch delta 2359 zcmbtWPiP%Q7~kErO_RQw_mbu{L}F?L3zkV{XJ>YI{DbYqJR)i|5)<*@%+9P9B~gzIksZRWnxKwrtp z$55eJ*qEF)wN=#N6-Lk8JK1l3Dt$ir{~gq6noy|{L}MBviX}!dTo9$P2LCuCB9hsc z)1S3pb=vi&Hk)+04Ltw;30EZkHd!;pGApXA3&}Tyu`(<}Kq+ zJUw$i?uqQ4CaC!fR(4q7T2ZezboBzvn+I)}mwNjSZP;}fjeVf)R`cD`fO)O=pm`cU zunoV;>S5P2zu=>0!e2IjPIYI~wL9Hx_*A!R%GE!-j?rrZFJh^bk|QOtL^Pl&iZzW8 zj}pZ>6Fz2e(T;_ze9vIVb?<(LvxMfA7PN6ZhUcJuh;?=5hU$0Q0F z*AOvnBgQ!rk`t8jL=madSc>G0GnXM#o@?prP=Zt%BFTZ*RQr$*j7WrI!IYLF7K;Cu z;r-^rsT0}j;+*SsjT^W6t=DBB^6RZq+D~;Hix@6NA_0X^M{q|B)e^^Ag)z~B0j0Zs zHY?$bSw}Z#{YQq}?C;0kKDcPZOx6nUK{-wkG}LJ;`x;Xa2a3tI#l6<#0u$}H^&1e) zRNpG3cIAi_cI>PQjRZ5l;+wK_3tpQUKJ{wO&2p=atuhMpg6AE3$=-7)C^$+35*@FqG%SAfW#UD%CZP9 z>j+Y5mto3jf2gDxNY_z?%(~*$^Vbf zl#S7=0FLPflpzu!a|_v9+Y~O7;h}wM{OeJ|c%pr-|6Sc~^cU)0f3jWeZ?Ez77ar*_ zb>!K{tSwku94MtZL>n`dY_vBa7?Wx0{%U)B^2PzYd2$$6_@J)w-pr#oHoN`7cUU}$ ze;zoF$Hb@jN*Zmaj_LZ!#-N9<9lwMd{iTl7Gz&}%qaijdgJL{F3`IhgHZ#dtR*6^D z-m64yc&NQTJwA>{pV@{V&OE!LuC`8%-_D%IGPke&Nj$&B>5rug#Ob51oOHHK7zU9y z3RE%yVj{U%HpN;V3J;>HcDzWOMtbdK|JW%0d{p9Z=ST4H>@OW$ky2n>6O4CRk_eKZ z8-mW+N#}iL#Y9|QxrZZZ8n20cIGD>FV5E#HM6Mtja)1iHA@ipIfo0u@=%v%@U-O+v zSIB&WnI0+mQb#3IX2~{+JjWWkWR#?-qdC1Q))--V@>R9xRf^kuyYS|%aU9ycx4m<| z9wN{SxV6TM9l;4rmSkv1rafhild4J;;6_?*yk*>&|E%%lk8gC)HJ0S1WDb&66l#hV z_-q_F;k+!gSm|85yz+V7<=-il(li=GQz9s>C3tN~OBZ946ptovS%Wf(*Vj&UXa|v) z3$keNCR$KgDDc8bu*v0;wIkQZs+zb)OM1|W?cMe7_u!$;{rKb6sfR5wzX{Y>kK@wC zHx50_<-~F|ws>a#EqEs{zI*oE;{CAx^MttiL6;&kTCzYh6IH4VWo3fk1p}_7*X4eD dC`MF2Yu7%xJb@?HcHtBsCM%7!Uv2*0`y08_*a83m From ec8aa6c84776a5ce78a5cc27e2457b6bf0fe6686 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Fri, 11 Jul 2025 16:46:01 +0000 Subject: [PATCH 2/2] Bump com.nimbusds:nimbus-jose-jwt Bumps [com.nimbusds:nimbus-jose-jwt](https://bitbucket.org/connect2id/nimbus-jose-jwt) from 4.41.1 to 10.0.2. - [Changelog](https://bitbucket.org/connect2id/nimbus-jose-jwt/src/master/CHANGELOG.txt) - [Commits](https://bitbucket.org/connect2id/nimbus-jose-jwt/branches/compare/10.0.2..4.41.1) --- updated-dependencies: - dependency-name: com.nimbusds:nimbus-jose-jwt dependency-version: 10.0.2 dependency-type: direct:production ... Signed-off-by: dependabot[bot] --- flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml index b5388cfac7766..a9d5ecaed7abc 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml +++ b/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml @@ -283,7 +283,7 @@ com.nimbusds nimbus-jose-jwt - 4.41.1 + 10.0.2