Bulk Operation

FLINK-10653 Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

FLINK-10653 Remove getBufferSize method from BufferPoolFactory

FLINK-10653 Refactor the process of SchedulerNG#requestPartitionState

FLINK-10653 Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes

FLINK-10653 Add partition lifecycle related Shuffle API

FLINK-10653 Remove ExecutionAttemptID argument from ResultPartitionFactory#create

FLINK-10653 Remove abstract getPageSize method from InputGate

FLINK-10653 Make shuffle environment implementation independent with IOManager

FLINK-10653 Introduce ShuffleService interface and its configuration

FLINK-10653 Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager

FLINK-10653 Refactor abstract InputGate to general interface

FLINK-10653 Remove getOwningTaskName method from InputGate

FLINK-10653 Make NetworkEnvironment#start() return the binded data port

FLINK-10653 Switch Task from ResultPartition to ResultPartitionWriter interface

FLINK-10653 Remove getBufferProvider method from ResultPartitionWriter interface

FLINK-10653 Introduce an encapsulated metric group layout for shuffle API and deprecate old one

FLINK-10653 Move Task.inputGatesById to NetworkEnvironment

FLINK-10653 Refactor the start method of ConnectionManager

FLINK-10653 Introduce partition/gate setup to decouple task registration with NetworkEnvironment

FLINK-10653 Move network metrics setup into NetworkEnvironment

FLINK-10653 Refactor ResultPartitionManager to break tie with Task

FLINK-10653 Consider introducing batch metric register in NetworkEnviroment

FLINK-10653 Introduce InputGateWithMetrics in Task to increment numBytesIn metric

FLINK-10653 Refactor IOMetrics to not distinguish between local/remote in/out bytes

FLINK-10653 Remove legacy fields for SingleInputGate

FLINK-10653 Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService

FLINK-10653 Move network related options to NetworkEnvironmentOptions

FLINK-10653 Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

FLINK-10653 Refactor the constructor of NetworkEnvironment

FLINK-10653 Refactor to simplify the process of scheduleOrUpdateConsumers

FLINK-10653 Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

FLINK-10653 Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

FLINK-10653 Remove KvState related components from NetworkEnvironment

FLINK-10653 Remove IOMode from NetworkEnvironment

FLINK-10653 Make InputGate interface extend AutoCloseable

FLINK-10653 Make ResultPartitionWriter extend AutoCloseable

FLINK-10653 Extend the necessary methods in ResultPartitionWriter interface

FLINK-10653 Remove the schedule mode property from RPDD to TDD

FLINK-10653 Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

FLINK-10653 Activate default shuffle implementation and remove legacy code

FLINK-10653 Introduce ShuffleEnvironment in Task Executor

FLINK-10653 Introduce ShuffleMaster in Job Master