[
https://issues.apache.org/jira/browse/FLINK-39073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-39073:
-------------------------------
Assignee: Efrat Levitan
> Idle source splits are picked by watermark alignment
> ----------------------------------------------------
>
> Key: FLINK-39073
> URL: https://issues.apache.org/jira/browse/FLINK-39073
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Task
> Reporter: Efrat Levitan
> Assignee: Efrat Levitan
> Priority: Major
> Labels: runtime, source
>
> A split might emit watermarks into the future and then turn idle.
> Alignment check might incorrectly mark it paused, which will cause the warn
> "Split marked paused while still idle" to be logged.
> As allowed watermark advances, the split might be resumed, and be shown as
> active by the split metric, while should still be considered idle.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
