This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new db1b5c7c22 [flink] Fix flaky test duplicate nullable PK IT (#9117)
db1b5c7c22 is described below
commit db1b5c7c22d72fed3189d841ec89b98b39b3e5df
Author: Arnav Balyan <[email protected]>
AuthorDate: Mon Aug 10 14:13:01 2026 +0530
[flink] Fix flaky test duplicate nullable PK IT (#9117)
---
.../org/apache/paimon/flink/NullablePrimaryKeyITCase.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/NullablePrimaryKeyITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/NullablePrimaryKeyITCase.java
index 2cf988dd6c..c574588d55 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/NullablePrimaryKeyITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/NullablePrimaryKeyITCase.java
@@ -89,9 +89,14 @@ public class NullablePrimaryKeyITCase extends
CatalogITCaseBase {
+ "(CAST(NULL AS INT), 'null-v2'), "
+ "(1, 'one')");
- // Without a sequence field, either value may win within the same
commit.
- assertThat(sql("SELECT id FROM T"))
- .containsExactlyInAnyOrder(Row.of((Object) null), Row.of(1));
+ assertThat(sql("SELECT * FROM T"))
+ .hasSize(2)
+ .contains(Row.of(1, "one"))
+ .anySatisfy(
+ row -> {
+ assertThat(row.getField(0)).isNull();
+ assertThat(row.getField(1)).isIn("null-v1",
"null-v2");
+ });
}
@Test
