(paimon) branch master updated: [core] Optimize latest snapshot retrieval for file store writers. (#8692)

[lzljs3620320]

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 5ad505ca5a [core] Optimize latest snapshot retrieval for file store 
writers. (#8692)
5ad505ca5a is described below

commit 5ad505ca5a84843f59be63a2e882081e330bde4a
Author: Master.TJ <798750...@qq.com>
AuthorDate: Thu Jul 16 22:09:59 2026 +0800

    [core] Optimize latest snapshot retrieval for file store writers. (#8692)
---
 .../java/org/apache/paimon/operation/AbstractFileStoreWrite.java     | 2 +-
 .../src/test/java/org/apache/paimon/rest/RESTCatalogTest.java        | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
 
b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
index 214cfbb603..e83f5e81c1 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
@@ -490,7 +490,7 @@ public abstract class AbstractFileStoreWrite<T> implements 
FileStoreWrite<T> {
             }
         }
 
-        Snapshot latestSnapshot = snapshotManager.latestSnapshot();
+        Snapshot latestSnapshot = 
snapshotManager.latestSnapshotFromFileSystem();
         boolean actualIgnorePreviousFiles =
                 ignorePreviousFilesForWriter(
                         partition, bucket, latestSnapshot, 
ignorePreviousFiles);
diff --git 
a/paimon-core/src/test/java/org/apache/paimon/rest/RESTCatalogTest.java 
b/paimon-core/src/test/java/org/apache/paimon/rest/RESTCatalogTest.java
index 4cac0d13c9..4092271bbf 100644
--- a/paimon-core/src/test/java/org/apache/paimon/rest/RESTCatalogTest.java
+++ b/paimon-core/src/test/java/org/apache/paimon/rest/RESTCatalogTest.java
@@ -109,7 +109,6 @@ import org.junit.jupiter.api.io.TempDir;
 
 import java.io.File;
 import java.io.IOException;
-import java.io.UncheckedIOException;
 import java.time.ZoneOffset;
 import java.time.ZonedDateTime;
 import java.util.ArrayList;
@@ -2151,7 +2150,7 @@ public abstract class RESTCatalogTest extends 
CatalogTestBase {
         FileStoreTable tableTestWrite = (FileStoreTable) 
catalog.getTable(identifier);
         List<Integer> data = Lists.newArrayList(12);
         Exception exception =
-                assertThrows(UncheckedIOException.class, () -> 
batchWrite(tableTestWrite, data));
+                assertThrows(RuntimeException.class, () -> 
batchWrite(tableTestWrite, data));
         assertEquals(RESTTestFileIO.TOKEN_EXPIRED_MSG, 
exception.getCause().getMessage());
         RESTToken dataToken =
                 new RESTToken(
@@ -2176,7 +2175,7 @@ public abstract class RESTCatalogTest extends 
CatalogTestBase {
         restTokenFileIO.isObjectStore();
         resetDataTokenOnRestServer(identifier);
         Exception exception =
-                assertThrows(UncheckedIOException.class, () -> 
batchWrite(tableTestWrite, data));
+                assertThrows(RuntimeException.class, () -> 
batchWrite(tableTestWrite, data));
         assertEquals(RESTTestFileIO.TOKEN_UN_EXIST_MSG, 
exception.getCause().getMessage());
     }