From 9827fa71421d5d49fe9c96dd7fa67dbd6509fa89 Mon Sep 17 00:00:00 2001
From: Leonard Xu <xbjtdcq@gmail.com>
Date: Thu, 8 Apr 2021 21:47:21 +0800
Subject: [PATCH] minor

---
 .../org/apache/flink/table/runtime/util/TimeWindowUtil.java   | 4 ++++
 1 file changed, 4 insertions(+)

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;
     }