This is an automated email from the ASF dual-hosted git repository.

JingsongLi 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 5b654cae4d [core] Disable snapshot expiry in 
testDiscardDuplicateFilesMultiThread (#8058)
5b654cae4d is described below

commit 5b654cae4da36c4f6b506df9e225f1ebae9b799d
Author: Arnav Balyan <[email protected]>
AuthorDate: Mon Jun 1 06:28:24 2026 +0530

    [core] Disable snapshot expiry in testDiscardDuplicateFilesMultiThread 
(#8058)
---
 .../java/org/apache/paimon/table/AppendOnlySimpleTableTest.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/paimon-core/src/test/java/org/apache/paimon/table/AppendOnlySimpleTableTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/table/AppendOnlySimpleTableTest.java
index 1ffd4669d4..4981d95453 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/table/AppendOnlySimpleTableTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/table/AppendOnlySimpleTableTest.java
@@ -320,7 +320,12 @@ public class AppendOnlySimpleTableTest extends 
SimpleTableTestBase {
     public void testDiscardDuplicateFilesMultiThread() throws Exception {
         FileStoreTable table =
                 createFileStoreTable(
-                        options -> 
options.set(CoreOptions.COMMIT_DISCARD_DUPLICATE_FILES, true));
+                        options -> {
+                            
options.set(CoreOptions.COMMIT_DISCARD_DUPLICATE_FILES, true);
+                            // Keep all snapshots so concurrent expiry does 
not race readers.
+                            options.set(CoreOptions.SNAPSHOT_NUM_RETAINED_MIN, 
1000);
+                            options.set(CoreOptions.SNAPSHOT_NUM_RETAINED_MAX, 
1000);
+                        });
         BatchWriteBuilder writeBuilder = table.newBatchWriteBuilder();
         List<List<CommitMessage>> messages = new ArrayList<>();
         for (int i = 0; i < 10; i++) {

Reply via email to