Bulk Operation

FLINK-8581 Notify data available to network stack immediately after finishing BufferBuilder

FLINK-8581 Move data available notification in PipelinedSubpartition out of the synchronized block

FLINK-8581 Reduce number of flush requests to the network stack

FLINK-8581 Add network profiling/diagnosing metrics.

FLINK-8581 SpillableSubpartitionView#getNextBuffer always sets isMoreAvailable to false when switching from spillable to spilled

FLINK-8581 Correctly set `moreAvailable` flag in SingleInputGate and UnionInputGate

FLINK-8581 SpilledSubpartitionView wrongly relys on the backlog for determining whether more data is available

FLINK-8581 InputGate may contain data after an EndOfPartitionEvent

FLINK-8581 Creating a union of UnionGate instances will fail with UnsupportedOperationException when retrieving buffers

FLINK-8581 Memory segment offsets for slices of slices are wrong

FLINK-8581 SpillableSubpartition does not update byte statistics when spilled by a SpillableSubpartitionView

FLINK-8581 SpillableSubpartition#spillFinishedBufferConsumers() does not count spilled bytes anymore

FLINK-8581 Make notifyDataAvailable call reliable

FLINK-8581 Efficiently handle alwaysFlush case (0ms flushTimeout)

FLINK-8581 Handle unfinished BufferConsumers in subpartitions

FLINK-8581 Drop ResultPartitionWriter#writeBufferToAllSubpartitions method

FLINK-8581 Add data polling method to InputGate

FLINK-8581 Handle sliced buffers in RecordDeserializer

FLINK-8581 Drop unused AdaptiveSpanningRecordDeserializer

FLINK-8581 Drop SpilledSubpartitionViewTest

FLINK-8581 Handle read-only buffers in DataInputDeserializer

FLINK-8581 Pass BufferConsumer to subpartitions

FLINK-8581 Introduce BufferConsumer concept