diff --git a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowUtil.java b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowUtil.java
index d0cc8688cf0395..4fbaf215ec116b 100644
--- a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowUtil.java
+++ b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowUtil.java
@@ -173,6 +173,10 @@ public static ZoneId getShiftTimeZone(LogicalType timeAttributeType, TableConfig
      */
     public static boolean isWindowFired(
             long windowEnd, long currentProgress, ZoneId shiftTimeZone) {
+        // Long.MAX_VALUE is a flag of min window end, directly return it
+        if (windowEnd == Long.MAX_VALUE) {
+            return false;
+        }
         long windowTriggerTime = toEpochMillsForTimer(windowEnd - 1, shiftTimeZone);
         return currentProgress >= windowTriggerTime;
     }