You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/01/28 12:48:26 UTC
[flink] branch master updated: [hotfix][docs] Remove redundant word
in BarrierBuffer comment
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz 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 641d6e6 [hotfix][docs] Remove redundant word in BarrierBuffer comment
641d6e6 is described below
commit 641d6e6c2548d233a2012faa7c27bfbb617f2883
Author: leesf <49...@qq.com>
AuthorDate: Mon Jan 28 20:48:13 2019 +0800
[hotfix][docs] Remove redundant word in BarrierBuffer comment
---
.../main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
index 991635a..cbeb4ba 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
@@ -187,7 +187,7 @@ public class BarrierBuffer implements CheckpointBarrierHandler {
BufferOrEvent bufferOrEvent = next.get();
if (isBlocked(bufferOrEvent.getChannelIndex())) {
- // if the channel is blocked we, we just store the BufferOrEvent
+ // if the channel is blocked, we just store the BufferOrEvent
bufferBlocker.add(bufferOrEvent);
checkSizeLimit();
}