You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ie...@apache.org on 2019/05/08 06:08:43 UTC

[beam] 01/01: Merge pull request #8495: [BEAM-7197] ensure DoFn is torn down after exception thrown in lifecycle method

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 7cdda3ca4be607c4079bbb90406b395d50c283da
Merge: bfd88c8 80e2cef
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Wed May 8 08:08:30 2019 +0200

    Merge pull request #8495: [BEAM-7197] ensure DoFn is torn down after exception thrown in lifecycle method

 .../beam/runners/direct/DoFnLifecycleManager.java  |  2 +-
 .../translation/functions/FlinkDoFnFunction.java   |  6 +-
 .../functions/FlinkStatefulDoFnFunction.java       |  6 +-
 .../spark/translation/MultiDoFnFunction.java       |  2 +-
 .../spark/translation/SparkProcessContext.java     | 22 +++---
 .../beam/sdk/transforms/reflect/DoFnInvokers.java  | 22 ++++++
 .../beam/sdk/transforms/ParDoLifecycleTest.java    | 89 +++++++++++++++++++++-
 7 files changed, 128 insertions(+), 21 deletions(-)