[FLINK-10740] FLIP-27: Refactor Source Interface

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: API / DataSet, API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available usability
• Assignee: Unassigned
• Reporter: Aljoscha Krettek
• Created: 31/Oct/18 16:16
• Updated: 16/Jul/22 10:38

Description

Please see the FLIP for any details: https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface

Issue Links

• blocks: FLINK-7286 Flink Dashboard fails to display bytes/records received by sources / emitted by sinks
• is related to: FLINK-22668 FLIP-150: Introduce Hybrid Source
• relates to: FLINK-21133 FLIP-27 Source does not work with synchronous savepoint
• links to: GitHub Pull Request #12492
• links to: GitHub Pull Request #13344
• mentioned in: Page Loading...

Sub-Tasks

• Add common metrics to the SourceReader base implementation.: Open
• Add metrics to the source coordinator.: Open