[test] Fix unstable case: ContinuousFileStoreITCase.testIgnoreDelete

apache · Jul 8, 2024 · 2bffa69 · 2bffa69
1 parent 3b36211
commit 2bffa69
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../paimon-flink-common/src/test/java/org/apache/paimon/flink/ContinuousFileStoreITCase.java b/.../paimon-flink-common/src/test/java/org/apache/paimon/flink/ContinuousFileStoreITCase.java
@@ -559,7 +559,7 @@ public void testIgnoreDelete() throws Exception {
 
         BlockingIterator<Row, Row> iterator =
                 streamSqlBlockIter(
-                        "SELECT * FROM ignore_delete /*+ OPTIONS('continuous.discovery-interval' = '1s') */");
+                        "SELECT * FROM ignore_delete /*+ OPTIONS('continuous.discovery-interval' = '1s', 'scan.snapshot-id' = '1') */");
 
         sql("INSERT INTO ignore_delete VALUES (1, 'A'), (2, 'B')");
         sql("DELETE FROM ignore_delete WHERE pk = 1");