Roman Khachatryan created FLINK-35933: -----------------------------------------
Summary: Skip distributing maxAllowedWatermark if there are no subtasks Key: FLINK-35933 URL: https://issues.apache.org/jira/browse/FLINK-35933 Project: Flink Issue Type: Improvement Components: Runtime / Coordination Reporter: Roman Khachatryan Assignee: Roman Khachatryan Fix For: 1.20.0 On JM, `SourceCoordinator.announceCombinedWatermark` executes unnecessary if there are no subtasks to distribute maxAllowedWatermark. This involves Heap and ConcurrentHashMap accesses and lots of logging. -- This message was sent by Atlassian Jira (v8.20.10#820010)