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 faacb7e1af [flink] Fix flaky Lumina data evolution index refresh IT
(#9153)
faacb7e1af is described below
commit faacb7e1af3967805056103edb6d6f6cdddf6410
Author: Arnav Balyan <[email protected]>
AuthorDate: Tue Aug 11 14:06:14 2026 +0530
[flink] Fix flaky Lumina data evolution index refresh IT (#9153)
---
.../java/org/apache/paimon/flink/LuminaVectorGlobalIndexITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LuminaVectorGlobalIndexITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LuminaVectorGlobalIndexITCase.java
index 4bc4056486..e559e9301b 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LuminaVectorGlobalIndexITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LuminaVectorGlobalIndexITCase.java
@@ -519,7 +519,7 @@ public class LuminaVectorGlobalIndexITCase extends
CatalogITCaseBase {
sql(
"CALL sys.data_evolution_merge_into("
+ "'default.T_REFRESH', '', '', 'S_REFRESH', "
- + "'T_REFRESH._ROW_ID=S_REFRESH.id', 'v=S_REFRESH.v',
2)");
+ + "'T_REFRESH.id=S_REFRESH.id', 'v=S_REFRESH.v', 2)");
assertThat(sql("SELECT id FROM T_REFRESH WHERE id = 1 AND v IS NOT
NULL")).hasSize(1);
long updatedSnapshotId = table.snapshotManager().latestSnapshot().id();