From 2bffa69d7b0bbc4fabaa4edbfffe7b301ec9abcc Mon Sep 17 00:00:00 2001
From: Jingsong <jingsonglee0@gmail.com>
Date: Mon, 8 Jul 2024 17:23:07 +0800
Subject: [PATCH] [test] Fix unstable case:
 ContinuousFileStoreITCase.testIgnoreDelete

---
 .../java/org/apache/paimon/flink/ContinuousFileStoreITCase.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ContinuousFileStoreITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ContinuousFileStoreITCase.java
index ff987fddd65b..54c193801fc8 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ContinuousFileStoreITCase.java
+++ b/paimon-flink/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");