Daniel Oliveira created BEAM-11019:
--------------------------------------
Summary: Adjust SDF progress reporting to account for multi-window
elements.
Key: BEAM-11019
URL: https://issues.apache.org/jira/browse/BEAM-11019
Project: Beam
Issue Type: Sub-task
Components: sdk-go
Reporter: Daniel Oliveira
Assignee: Daniel Oliveira
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
