This is an automated email from the ASF dual-hosted git repository.

tison 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 99ef937  [hotfix][doc] Remove invalid comment from 
CheckpointedInputGate
99ef937 is described below

commit 99ef937ed48a176c8bba4e82f2142033504d4685
Author: zhijiang <[email protected]>
AuthorDate: Sun Jan 5 09:17:04 2020 +0800

    [hotfix][doc] Remove invalid comment from CheckpointedInputGate
    
    This closes #10729 .
---
 .../org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java     | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
index 317cd84..0bc496f 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
@@ -125,7 +125,6 @@ public class CheckpointedInputGate implements 
PullingAsyncDataInput<BufferOrEven
                                next = inputGate.pollNext();
                        }
                        else {
-                               // TODO: FLINK-12536 for non credit-based flow 
control, getNext method is blocking
                                next = bufferStorage.pollNext();
                                if (!next.isPresent()) {
                                        return pollNext();

Reply via email to