Bulk Operation

FLINK-10740 SourceReaderContext should give access to Configuration and Hostbame

FLINK-10740 Allow Split Reader based sources to reuse record batches

FLINK-10740 Port File Sources to FLIP-27 API

FLINK-10740 Improve RecordsWithSplitIds API

FLINK-10740 Add documentation for new FLIP-27 source interface

FLINK-10740 Add the subtask index information to the SourceReaderContext.

FLINK-10740 Change SourceCoordinator to handle resetToCheckpoint() call after started.

FLINK-10740 Evolve WatermarkOutputMultiplexer to make it reusable in FLIP-27 Sources

FLINK-10740 Integrate FLIP-126 Timestamps and Watermarking with FLIP-27 sources

FLINK-10740 Remove Exceptions from signatures of SourceOutput methods

FLINK-10740 Resolve stability annotations discussion for FLIP-27 in 1.11

FLINK-10740 OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread

FLINK-10740 FutureCompletingBlockingQueue should have a capacity limit.

FLINK-10740 OperatorCoordinators must be notified of tasks cancelled as part of failover

FLINK-10740 Reduce scope for SourceOperator arguments and initialize more eagerly

FLINK-10740 Simplify SourceOperator by using a utility SimpleVersionedListState

FLINK-10740 Add failure reason to OperatorCoordinator.failTask(...)

FLINK-10740 OperatorCoordinators receive failure notifications on task failure instead of on task restarts

FLINK-10740 Update the interfaces to PublicEvolving and add documentation.

FLINK-10740 Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

FLINK-10740 Enhance the OperatorEvent handling guarantee during checkpointing.

FLINK-10740 Add metrics to the source coordinator.

FLINK-10740 Add common metrics to the SourceReader base implementation.

FLINK-10740 Improve the performance of the RecordsWithSplitIds queue.

FLINK-10740 Implement SourceReaderOperator which runs the SourceReader.

FLINK-10740 Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

FLINK-10740 Prerequisite cleanups and refactorings in the Checkpoint Coordinator

FLINK-10740 Integrate Operator Coordinators with Checkpoints

FLINK-10740 Add Source API classes

FLINK-10740 Allow users to construct a DataStream from a new Source API

FLINK-10740 Add implementation for SourceCoordinator

FLINK-10740 Add the interface and base implementation for SourceReader.

FLINK-10740 Implement OperatorEvent passing RPC.