[jira] [Assigned] (BEAM-4665) beam.Run() should join a running dataflow pipeline on process restart.

["Danny McCormick (Jira)" <ji...@apache.org>]

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

Danny McCormick reassigned BEAM-4665:
-------------------------------------

    Assignee: Danny McCormick

> beam.Run() should join a running dataflow pipeline on process restart.
> ----------------------------------------------------------------------
>
>                 Key: BEAM-4665
>                 URL: https://issues.apache.org/jira/browse/BEAM-4665
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-go
>    Affects Versions: 2.5.0
>            Reporter: Eduardo Morales
>            Assignee: Danny McCormick
>            Priority: P3
>              Labels: starter
>
> as of 2.5.0-RC1, beam.Run() returns the following error:
> 2018/06/25 20:10:46 Failed to execute job: googleapi: Error 409: (acbae89877e14d87): The workflow could not be created. Causes: (590297f494c27357): There is already an active job named xxx-yyy_zzz. If you want to submit a second job, try again by setting a different name., alreadyExists
>  
> if running in async mode, I would expect beam.Run() to just return without any error.
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)