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();