You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by GitBox <gi...@apache.org> on 2019/01/15 09:19:57 UTC
[flink] Diff for: [GitHub] asfgit closed pull request #7485: [hotfix][docs]
Remove expired comments and fix typo
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 644d57c8abc..8bd3534f44f 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;
With regards,
Apache Git Services