diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java index 644d57c8abcee..8bd3534f44f06 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java @@ -53,10 +53,8 @@ public SourceStreamTask(Environment env) { @Override protected void init() { - // does not hold any resources, so no initialization needed - // we check if the source is actually inducing the checkpoints, rather - // than the trigger ch + // than the trigger SourceFunction source = headOperator.getUserFunction(); if (source instanceof ExternallyInducedSource) { externallyInducedCheckpoints = true;