Amit Sela created BEAM-647:
Summary: Faul-tolerant sideInputs via Broadcast variables.
Issue Type: Bug
Reporter: Amit Sela
Assignee: Amit Sela
Following https://github.com/apache/incubator-beam/pull/909 which enables
checkpointing to recover from failures, sideInputs (being implemented by
broadcast variables) should be handled in a specific manner as described here:
This is a bit more complicated than Aggregators (via Accumulators) as they are
implemented using a single "aggregating" Accumulator, while a pipeline may
contain multiple sideInputs.
This message was sent by Atlassian JIRA