[
https://issues.apache.org/jira/browse/BEAM-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-3187:
-------------------------------
Description:
The lifecycle of the DoFn is not respected in the case of an Exception on the
finishBundle method. The Spark runner does not call the teardown function of
the DoFn as it should since this should be dual with the setup.
This happens too if the exception happens in the startBundle too.
was:The lifecycle of the DoFn is not respected in the case of an Exception on
the finishBundle method. The Spark runner does not call the teardown function
of the DoFn as it should since this should be dual with the setup.
> Spark runner does not call the teardown function if DoFn throws Exception on
> finishBundle
> -----------------------------------------------------------------------------------------
>
> Key: BEAM-3187
> URL: https://issues.apache.org/jira/browse/BEAM-3187
> Project: Beam
> Issue Type: Bug
> Components: runner-spark
> Affects Versions: 2.1.0
> Reporter: Ismaël Mejía
> Assignee: Ismaël Mejía
>
> The lifecycle of the DoFn is not respected in the case of an Exception on the
> finishBundle method. The Spark runner does not call the teardown function of
> the DoFn as it should since this should be dual with the setup.
> This happens too if the exception happens in the startBundle too.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)