From 71999154eac57c2736abd5b14ce921fd3f92cdb9 Mon Sep 17 00:00:00 2001 From: Arnav Balyan Date: Mon, 10 Aug 2026 16:48:08 +0530 Subject: [PATCH] update --- .../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 4bc405648611..e559e9301bc3 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 void testDataEvolutionUpdateRefreshesIndexAtomically() throws Exception { 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();