There are multiple MAX_LONG_VALUE values sys. In pyflink code maxsize

apache · Mar 16, 2022 · 6c2a22d · 6c2a22d
1 parent def4163
commit 6c2a22d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-python/pyflink/fn_execution/table/window_aggregate_slow.py b/flink-python/pyflink/fn_execution/table/window_aggregate_slow.py
@@ -22,6 +22,7 @@
 import pytz
 
 from pyflink.common import Row, RowKind
+from pyflink.common.constants import MAX_LONG_VALUE
 from pyflink.fn_execution.datastream.timerservice import InternalTimer
 from pyflink.fn_execution.datastream.timerservice_impl import LegacyInternalTimerServiceImpl
 from pyflink.fn_execution.coders import PickleCoder
@@ -32,8 +33,7 @@
     MergingWindowAssigner
 from pyflink.fn_execution.table.window_context import WindowContext, TriggerContext, K, W
 from pyflink.fn_execution.table.window_process_function import GeneralWindowProcessFunction, \
-    InternalWindowProcessFunction, PanedWindowProcessFunction, MergingWindowProcessFunction, \
-    MAX_LONG_VALUE
+    InternalWindowProcessFunction, PanedWindowProcessFunction, MergingWindowProcessFunction
 from pyflink.fn_execution.table.window_trigger import Trigger
 from pyflink.table.udf import ImperativeAggregateFunction, FunctionContext