Niel Markwick created BEAM-9505:
-----------------------------------

             Summary: DoFn.StartBundle called multiple times when streaming
                 Key: BEAM-9505
                 URL: https://issues.apache.org/jira/browse/BEAM-9505
             Project: Beam
          Issue Type: Bug
          Components: runner-dataflow
    Affects Versions: 2.19.0, 2.18.0
            Reporter: Niel Markwick


When using DataflowRunner in streaming mode. DoFn.StartBundle is called 
multiple times for the same bundle.

 

This does not occur with DirectRunner. 

This breaks DoFn's which require per-bundle setup and teardown  procedures.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to