diff --git a/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java b/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java
index 29bc345030dd..5b046e752f4e 100644
--- a/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java
+++ b/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java
@@ -56,7 +56,7 @@ private WatermarkExtractor(ZoneId watermarkZoneId) {
 
         @Override
         public Optional<LocalDateTime> extract(long timeMilli, @Nullable Long watermark) {
-            if (watermark == null || watermark < 0) {
+            if (watermark == null || watermark == Long.MIN_VALUE) {
                 return Optional.empty();
             }