[hotfix] [datastream] Remove irrelevant comments and fix typo in Sour…

…ceStreamTask This closes apache#7485.
mbalassi · Jan 15, 2019 · baea9a3 · baea9a3
1 parent e5e6274
commit baea9a3
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...reaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java b/...reaming-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;