[FLINK-20491] Support Broadcast Operation in BATCH execution mode

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 04/Dec/20 15:55
• Updated: 28/May/21 07:10
• Resolved: 07/Jan/21 11:17

Description

Right now, we don't support DataStream.connect(BroadcastStream) in BATCH execution mode. I believe we can add support for this with not too much work.

The key insight is that we can process the broadcast side before the non-broadcast side. Initially, we were shying away from this because of concerns about ctx.applyToKeyedState() which allows the broadcast side of the user function to access/iterate over state from the keyed side. We thought that we couldn't support this. However, since we know that we process the broadcast side first we know that the keyed side will always be empty when doing so. We can thus just make this "keyed iteration" call a no-op, instead of throwing an exception as we do now.

Issue Links

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