minor

apache · Apr 8, 2021 · 9827fa7 · 9827fa7
1 parent 7f9fcc2
commit 9827fa7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowUtil.java b/...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;
     }