zhijiangW commented on a change in pull request #10347: [FLINK-14516][network]
Remove non credit-based flow control code
URL: https://github.com/apache/flink/pull/10347#discussion_r352438110
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java
##########
@@ -35,11 +40,31 @@
* alignment in exactly-once mode.
*/
@Internal
-public class CachedBufferStorage extends AbstractBufferStorage {
+public class CachedBufferStorage implements BufferStorage {
+ private static final Logger LOG =
LoggerFactory.getLogger(CachedBufferStorage.class);
+
+ /**
+ * The pending blocked buffer/event sequences. Must be consumed before
requesting further data
+ * from the input gate.
+ */
+ protected final ArrayDeque<BufferOrEventSequence> queuedBuffered = new
ArrayDeque<>();
+
+ protected final long maxBufferedBytes;
+
+ protected final String taskName;
/** The page size, to estimate the total cached data size. */
private final int pageSize;
+ /**
+ * The sequence of buffers/events that has been unblocked and must now
be consumed before
+ * requesting further data from the input gate.
+ */
+ protected BufferOrEventSequence currentBuffered;
+
+ /** The number of bytes in the queued spilled sequences. */
Review comment:
spilled->cached
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
