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();

Reply via email to