You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/12/12 12:49:41 UTC
[3/3] flink git commit: [hotfix][javadoc] Fix typo in StreamElement
javadoc
[hotfix][javadoc] Fix typo in StreamElement javadoc
This closes #5152.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0b024aad
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0b024aad
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0b024aad
Branch: refs/heads/release-1.4
Commit: 0b024aad17e1d8a0ea69a9b5651eb750385ebdea
Parents: f00e729
Author: Matrix42 <93...@qq.com>
Authored: Tue Dec 12 18:10:15 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Tue Dec 12 13:49:21 2017 +0100
----------------------------------------------------------------------
.../apache/flink/streaming/runtime/streamstatus/StreamStatus.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0b024aad/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java
index 8e58340..3dee61c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java
@@ -63,7 +63,7 @@ import org.apache.flink.streaming.runtime.tasks.StreamTask;
* active. However, for watermarks, since there may be watermark generators that might produce watermarks
* anywhere in the middle of topologies regardless of whether there are input data at the operator, the current
* status of the task must be checked before forwarding watermarks emitted from
- * an operator. It the status is actually idle, the watermark must be blocked.
+ * an operator. If the status is actually idle, the watermark must be blocked.
*
* <li>For downstream tasks with multiple input streams, the watermarks of input streams that are temporarily idle,
* or has resumed to be active but its watermark is behind the overall min watermark of the operator, should not