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 2024/07/08 09:23:47 UTC
(paimon) branch master updated: [test] Fix unstable case: ContinuousFileStoreITCase.testIgnoreDelete
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 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 2bffa69d7 [test] Fix unstable case: ContinuousFileStoreITCase.testIgnoreDelete
2bffa69d7 is described below
commit 2bffa69d7b0bbc4fabaa4edbfffe7b301ec9abcc
Author: Jingsong <ji...@gmail.com>
AuthorDate: Mon Jul 8 17:23:07 2024 +0800
[test] Fix unstable case: ContinuousFileStoreITCase.testIgnoreDelete
---
.../test/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 ff987fddd..54c193801 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 class ContinuousFileStoreITCase extends CatalogITCaseBase {
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");