[ 
https://issues.apache.org/jira/browse/BEAM-11019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Daniel Oliveira updated BEAM-11019:
-----------------------------------
    Summary: Adjust Go SDF progress reporting to account for multi-window 
elements.  (was: Adjust SDF progress reporting to account for multi-window 
elements.)

> Adjust Go 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
>            Priority: P2
>
> 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)

Reply via email to