[
https://issues.apache.org/jira/browse/BEAM-12528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Cwik updated BEAM-12528:
-----------------------------
Fix Version/s: 2.32.0
Resolution: Fixed
Status: Resolved (was: Open)
> Don't reuse failed plans.
> -------------------------
>
> Key: BEAM-12528
> URL: https://issues.apache.org/jira/browse/BEAM-12528
> Project: Beam
> Issue Type: Bug
> Components: sdk-go
> Reporter: Robert Burke
> Assignee: Robert Burke
> Priority: P2
> Fix For: 2.32.0
>
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> Failed plans get re-appended to the list of plans unconditionally.
>
> [https://github.com/apache/beam/blob/cf8ffe660cfcb1f7d421171f406fa991b93e043b/sdks/go/pkg/beam/core/runtime/harness/harness.go#L315]
>
> Which means there's a risk that a new bundle using the same bundle descriptor
> might re-use a failed plan.
>
> [https://github.com/apache/beam/blob/cf8ffe660cfcb1f7d421171f406fa991b93e043b/sdks/go/pkg/beam/core/runtime/harness/harness.go#L236]
>
> While users should be resetting everything in StartBundle, that's not
> necessarily the case. It would be easier on users when plans are re-used to
> recreate them on failures.
>
> After a certain point plans are garbage collected already, both failed and
> successful.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
