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.
  */