You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2018/01/07 11:16:01 UTC

[jira] [Resolved] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions

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

Ismaël Mejía resolved BEAM-3187.
--------------------------------
       Resolution: Fixed
    Fix Version/s: 2.3.0

> Spark runner does not respect ParDo's lifecycle on case of exceptions
> ---------------------------------------------------------------------
>
>                 Key: BEAM-3187
>                 URL: https://issues.apache.org/jira/browse/BEAM-3187
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-spark
>    Affects Versions: 2.2.0
>            Reporter: Ismaël Mejía
>            Assignee: Ismaël Mejía
>             Fix For: 2.3.0
>
>
> 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)