[BEAM-11019] Adjust Go SDF progress reporting to account for multi-window elements.

• 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:55
• Updated: 08/Dec/20 01:52
• Resolved: 08/Dec/20 01:52

Description

SDF progress reporting should account for exploded windows. For example, if an element being processed is in three windows, and those windows get exploded, then it essentially is being processed 3 times. So after the first window's done, progress should be at 1/3, then at 2/3 after the second, and so on. Instead, at the moment progress is only reported for the current element which means it'll constantly loop from 0 -> 1.0 over and over as the element gets processed in each window.

Issue Links

• links to: GitHub Pull Request #13013