This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9bdcfacf7212715cf194854886143593896b2bfc Author: Piotr Nowojski <[email protected]> AuthorDate: Wed Jun 26 16:30:12 2019 +0200 [hotfix][network] Drop unneccessary reference in the comment This reference was introducing unwanted dependency between CachedBufferStorage and a class that was using it. --- .../java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java index 4927c35..318497d 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java @@ -118,7 +118,7 @@ public class CachedBufferStorage extends AbstractBufferStorage { */ public static class CachedBufferOrEventSequence implements BufferOrEventSequence { - /** The sequence of buffers and events to be consumed by {@link CheckpointedInputGate}.*/ + /** The sequence of buffers and events to be consumed. */ private final ArrayDeque<BufferOrEvent> queuedBuffers; /** The total size of the cached data. */
