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 2020/06/04 06:32:22 UTC
[flink] branch master updated: [FLINK-18037][javadocs] Remove
duplicate word
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 079b38a [FLINK-18037][javadocs] Remove duplicate word
079b38a is described below
commit 079b38a5c2952eeac24661774bfaad58a746c115
Author: zhuxiaoshang <31...@users.noreply.github.com>
AuthorDate: Thu Jun 4 14:31:22 2020 +0800
[FLINK-18037][javadocs] Remove duplicate word
---
.../org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java
index 7134b44..c66b2d1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java
@@ -56,7 +56,7 @@ import static org.apache.flink.util.Preconditions.checkState;
* {@link StatusWatermarkValve} determines the {@link Watermark} from all inputs has advanced, or
* that a {@link StreamStatus} needs to be propagated downstream to denote a status change.
*
- * <p>Forwarding elements, watermarks, or status status elements must be protected by synchronizing
+ * <p>Forwarding elements, watermarks, or status elements must be protected by synchronizing
* on the given lock object. This ensures that we don't call methods on a
* {@link StreamInputProcessor} concurrently with the timer callback or other things.
*/