Xuyang Zhong created FLINK-38055:
------------------------------------
Summary: The internalTimerService must initialize watermark before
processing data
Key: FLINK-38055
URL: https://issues.apache.org/jira/browse/FLINK-38055
Project: Flink
Issue Type: Bug
Components: API / Python, Runtime / Task, Table SQL / Runtime
Affects Versions: 1.20.1, 2.0.0, 2.1.0
Reporter: Xuyang Zhong
Similar to https://issues.apache.org/jira/browse/FLINK-36663, it seems that for
other operators that use internalTimerService#currentWatermark to determine
whether the data is late, the watermark from the state need to be loaded in
advance to initialize the internalTimerService like window join/window rank in
table-runtime, cep, window/interval join operator in flink-runtime, window
operator in pyflink
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
