You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/08/11 08:36:21 UTC
(paimon) branch master updated: [flink] Fix flaky Lumina data evolution index refresh IT (#9153)
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 <60...@users.noreply.github.com>
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();