(flink) branch master updated: [hotfix] Do skip distributing maxAllowedWatermark if there are no subtasks

[pn...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new c6a026ea0b5 [hotfix] Do skip distributing maxAllowedWatermark if there are no subtasks
c6a026ea0b5 is described below

commit c6a026ea0b50bd574da46f9dbbba7dcaaa6f2246
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Tue Nov 26 13:44:10 2024 +0000

    [hotfix] Do skip distributing maxAllowedWatermark if there are no subtasks
---
 .../org/apache/flink/runtime/source/coordinator/SourceCoordinator.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
index 4a9c252a4a1..a1bf09be8fe 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java
@@ -178,6 +178,7 @@ public class SourceCoordinator<SplitT extends SourceSplit, EnumChkT>
                     "Skip distributing maxAllowedWatermark of group={} for source {} - no subtasks.",
                     watermarkAlignmentParams.getWatermarkGroup(),
                     operatorName);
+            return;
         }
         checkState(
                 watermarkAlignmentParams != WatermarkAlignmentParams.WATERMARK_ALIGNMENT_DISABLED);