(amoro) branch master updated: [Improvement]: Allow the snapshot watermark to be equal to the tagTriggerTime (#3714)

[jinsongzhou]

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

jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 9eef26fdb [Improvement]: Allow the snapshot watermark to be equal to 
the tagTriggerTime (#3714)
9eef26fdb is described below

commit 9eef26fdb5f914ab16c2fc74fe597467e64d012e
Author: cxxiii <139520856+cxx...@users.noreply.github.com>
AuthorDate: Wed Aug 6 19:15:37 2025 +0800

    [Improvement]: Allow the snapshot watermark to be equal to the 
tagTriggerTime (#3714)
    
    modify find condition for sanpshot
---
 .../amoro/server/optimizing/maintainer/AutoCreateIcebergTagAction.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/AutoCreateIcebergTagAction.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/AutoCreateIcebergTagAction.java
index 0369e1963..51ef16702 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/AutoCreateIcebergTagAction.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/AutoCreateIcebergTagAction.java
@@ -126,7 +126,7 @@ public class AutoCreateIcebergTagAction {
     Iterable<Snapshot> snapshots = table.snapshots();
     for (Snapshot snapshot : snapshots) {
       long waterMark = getWaterMark(table, snapshot);
-      if (waterMark > tagTriggerTime) {
+      if (waterMark >= tagTriggerTime) {
         return snapshot;
       }
     }