[ https://issues.apache.org/jira/browse/BEAM-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yueyang Qiu reassigned BEAM-6906: --------------------------------- Assignee: (was: Yueyang Qiu) > Mutating accumulators in fused stages is generally unsafe - need to provide a > single mutable accumulator > -------------------------------------------------------------------------------------------------------- > > Key: BEAM-6906 > URL: https://issues.apache.org/jira/browse/BEAM-6906 > Project: Beam > Issue Type: Bug > Components: beam-model > Reporter: Kenneth Knowles > Priority: Critical > Time Spent: 40m > Remaining Estimate: 0h > > Our current docs encourage a CombineFn author to mutate accumulators for > efficiency. This is important, but cannot be done generally without losing > efficiency - it is not safe to share accumulators within a stage or across > sliding windows. The ownership story needs to be clear. Any accumulator that > is mutable is from that point on owned by the CombineFn, not the runner and > cannot be given to other steps. -- This message was sent by Atlassian Jira (v8.3.4#803005)