From baea9a35a9dc209229fae043991b394c141b1265 Mon Sep 17 00:00:00 2001
From: leesf <490081539@qq.com>
Date: Mon, 14 Jan 2019 23:24:56 +0800
Subject: [PATCH] [hotfix] [datastream] Remove irrelevant comments and fix typo
 in SourceStreamTask

This closes #7485.
---
 .../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 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;