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 <[email protected]>
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.
*/
