Bulk Operation

FLINK-7282 Solve the potential deadlock problem when reducing exclusive buffers to zero

FLINK-7282 Remove the setting of netty channel watermark in NettyServer

FLINK-7282 Remove non credit based network code

FLINK-7282 Construct special test/benchmark to verify the backlog effect

FLINK-7282 Fix the calculation of backlog in PipelinedSubpartition

FLINK-7282 Introduce another greedy mechanism for distributing floating buffers

FLINK-7282 Initial credit should be configured in a separate parameter

FLINK-7282 Avoid recursion stack overflow during releasing SingleInputGate

FLINK-7282 Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

FLINK-7282 Lower the minimum number of buffers for incoming channels to 1

FLINK-7282 Make credit-based floating buffers optional

FLINK-7282 Adapt BackPressureStatsTracker to work with credit-based flow control

FLINK-7282 The tag of waiting for floating buffers in RemoteInputChannel should be updated properly

FLINK-7282 Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

FLINK-7282 Stop assigning floating buffers for blocked input channels in exactly-once mode

FLINK-7282 Add the switch for keeping both the old mode and the new credit-based mode

FLINK-7282 Define the BufferListener interface to replace EventListener in BufferProvider

FLINK-7282 Add credit field in PartitionRequest message

FLINK-7282 Implement sender backlog logic for credit-based

FLINK-7282 Implement Netty sender incoming pipeline for credit-based

FLINK-7282 Implement Netty receiver outgoing pipeline for credit-based

FLINK-7282 Implement Netty receiver incoming pipeline for credit-based

FLINK-7282 Manage exclusive buffers in RemoteInputChannel

FLINK-7282 Create a fix size (non rebalancing) buffer pool type for the floating buffers