Zakelly Lan created FLINK-36859:
-----------------------------------
Summary: Wrong epoch/watermark firing in async state processing
Key: FLINK-36859
URL: https://issues.apache.org/jira/browse/FLINK-36859
Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Reporter: Zakelly Lan
Assignee: Zakelly Lan
Currently, we use `EpochManager` to manage the watermark in async state
processing. We found an issue when a watermark reached and no further input
reach for a while, the epoch/watermark will be triggered twice.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
