[FLINK-19316] FLIP-134: Batch execution for the DataStream API

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Component/s: API / DataStream
• Assignee: Kostas Kloudas
• Reporter: Aljoscha Krettek
• Created: 21/Sep/20 09:04
• Updated: 18/May/21 13:04
• Resolved: 18/May/21 09:07

Description

Umbrella issue for FLIP-134

Issue Links

• Blocked: FLINK-20280 Support batch mode for Python DataStream API
• mentioned in: Page Loading...
• mentioned in: Page Loading...

Sub-Tasks

• Make EventTime the default StreamTimeCharacteristic: Closed
• Deprecate timeWindow() operations in DataStream API: Closed
• Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() and TimeCharacteristic: Closed
• Allow explicitly configuring time behaviour on CEP PatternStream: Closed
• Detect the execution mode based on the sources in the job.: Closed
• Allow explicitly configuring time behaviour on KeyedStream.intervalJoin(): Closed
• Decouple runtime operator implementation from DataStream operations: Closed
• Expose the execution.runtime-mode to the users: Closed
• Disable Checkpointing when in BATCH mode: Closed
• Disable FeedbackTransformation for BATCH mode: Closed
• Disable CoFeedbackTransformation for BATCH mode: Closed
• Don't emit intermediate watermarks from sources in BATCH execution mode: Closed
• Don't emit intermediate watermarks from watermark operators in BATCH execution mode: Closed
• Do not emit intermediate results for reduce operation BATCH execution mode: Closed
• Add "sanity-check" integration test for BATCH execution on DataStream API: Closed
• Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator: Closed
• Add documentation for BATCH execution mode: Closed
• Add setter in the environment for the `execution.runtime-mode`: Closed