[
https://issues.apache.org/jira/browse/BEAM-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny McCormick updated BEAM-4665:
----------------------------------
Fix Version/s: 2.37.0
Resolution: Fixed
Status: Resolved (was: Open)
> 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
> Fix For: 2.37.0
>
> Time Spent: 2h 40m
> Remaining Estimate: 0h
>
> 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)
