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