(paimon) branch master updated: [core] Optimize shouldDelaySnapshot in DataTableStreamScan

[lzljs3620320]

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 cd447dc5f4 [core] Optimize shouldDelaySnapshot in DataTableStreamScan
cd447dc5f4 is described below

commit cd447dc5f4f4e1ed29fecdde3e7554f02f8e78dd
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Tue Jul 22 12:05:53 2025 +0800

    [core] Optimize shouldDelaySnapshot in DataTableStreamScan
---
 .../org/apache/paimon/table/source/DataTableStreamScan.java    | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java
 
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java
index 25563ded2b..303e648d33 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java
@@ -211,7 +211,7 @@ public class DataTableStreamScan extends 
AbstractDataTableScan implements Stream
                 throw new EndOfScanException();
             }
 
-            if (shouldDelaySnapshot(nextSnapshotId)) {
+            if (shouldDelaySnapshot(snapshot)) {
                 return SnapshotNotExistPlan.INSTANCE;
             }
 
@@ -236,17 +236,13 @@ public class DataTableStreamScan extends 
AbstractDataTableScan implements Stream
         }
     }
 
-    private boolean shouldDelaySnapshot(long snapshotId) {
+    private boolean shouldDelaySnapshot(Snapshot snapshot) {
         if (scanDelayMillis == null) {
             return false;
         }
 
         long snapshotMills = System.currentTimeMillis() - scanDelayMillis;
-        if (snapshotManager.snapshotExists(snapshotId)
-                && snapshotManager.snapshot(snapshotId).timeMillis() > 
snapshotMills) {
-            return true;
-        }
-        return false;
+        return snapshot.timeMillis() > snapshotMills;
     }
 
     @Nullable