[FLINK-33202] FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 2.0.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Xuannan Su
• Created: 07/Oct/23 06:11
• Updated: 10/Jul/24 06:57

Description

Umbrella issue for https://cwiki.apache.org/confluence/display/FLINK/FLIP-327%3A+Support+switching+from+batch+to+stream+mode+to+improve+throughput+when+processing+backlog+data

Issue Links

• links to: GitHub Pull Request #23521
• mentioned in: Page Loading...

Sub-Tasks

• Propagate RecordAttributes that contains isProcessingBacklog status: Closed
• Support switching from batch to stream mode for one input stream operator: Open
• Support switching from batch to stream mode for KeyedCoProcessOperator and IntervalJoinOperator: Open
• Determine the initial status before receiving the first RecordAttributes: Open
• Introduce isInternalSorterSupport to OperatorAttributes: Closed