Bulk Operation

FLINK-14551 Update documentation taking unaligned checkpoints into the account

FLINK-14551 Add check for max concurrent checkpoints under UC mode

FLINK-14551 Provide ChannelStateReader#hasStates for hints of reading channel states

FLINK-14551 Support unaligned checkpoints for records spilled to files

FLINK-14551 Implement aligned savepoint in UC mode

FLINK-14551 Refactor the usages of ThreadSafeUnaligner#storeNewBuffers

FLINK-14551 Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

FLINK-14551 Enable unaligned checkpoints in tests by default

FLINK-14551 Add recovery to integration tests of unaligned checkpoints

FLINK-14551 Add checkpoint cancellation to Unaligner

FLINK-14551 Persist spilled records of SpillingAdaptiveSpanningRecordDeserializer

FLINK-14551 Implement API to persist channel state

FLINK-14551 Add basic CheckpointBarrierHandler for unaligned checkpoint

FLINK-14551 Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

FLINK-14551 Implement ResultPartition state recovery for unaligned checkpoint

FLINK-14551 Implement InputChannel state recovery for unaligned checkpoint

FLINK-14551 Implement API to persist channel state: checkpointing metadata

FLINK-14551 Add API to persist channel state

FLINK-14551 Respect non-blocking output in StreamTask#processInput

FLINK-14551 Introduce NetworkBufferPool#isAvailable() for non-blocking output

FLINK-14551 Implement back-pressure monitor with non-blocking outputs

FLINK-14551 Implement rudimentary non-blocking network output

FLINK-14551 Remove unnecessary interface method BufferProvider#requestBufferBlocking