[BEAM-11020] Fix multi-window SDF splitting in Go.

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: sdk-go
• Assignee: Daniel Oliveira
• Reporter: Daniel Oliveira
• Created: 05/Oct/20 19:59
• Updated: 08/Dec/20 01:51
• Resolved: 08/Dec/20 01:51

Description

When splitting an element that's being processed on multiple windows, currently the element gets split based on the current progress of the current element+window pair, and the primary and residual both contain all windows from the original. This is incorrect as certain windows in the residual have already been processed.

The correct way to perform this split is to put the element + all fully processed windows in the primary, the element + all fully unprocessed windows in the residual, and then only split the element at the current element + window pair.

This fix should already be in Java and Python, so those can be referenced.

Issue Links

• links to: GitHub Pull Request #13070