You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/15 09:17:43 UTC
[flink] 02/03: [hotfix] [datastream] Remove irrelevant comments and
fix typo in SourceStreamTask
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit baea9a35a9dc209229fae043991b394c141b1265
Author: leesf <49...@qq.com>
AuthorDate: Mon Jan 14 23:24:56 2019 +0800
[hotfix] [datastream] Remove irrelevant comments and fix typo in SourceStreamTask
This closes #7485.
---
.../org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
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 644d57c..8bd3534 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 class SourceStreamTask<OUT, SRC extends SourceFunction<OUT>, OP extends S
@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;