You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/07/01 14:41:23 UTC
[flink] 14/16: [hotfix][network] Drop unneccessary reference in the
comment
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 <pi...@gmail.com>
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. */