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

Posted to commits@beam.apache.org by ro...@apache.org on 2018/03/01 23:35:53 UTC

[beam] 01/01: Merge pull request #4372 from [BEAM-3409] Make DirectRunner waitUntilFinish() wait for the teardown

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

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

commit 85acc2637e2fce753dad749f90391f6d81b7ce2f
Merge: f358024 0044cbf
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Thu Mar 1 15:35:48 2018 -0800

    Merge pull request #4372 from [BEAM-3409] Make DirectRunner waitUntilFinish() wait for the teardown
    
    [BEAM-3409] waitUntilFinish() doesn't wait for the teardown execution on Direct runner

 .../org/apache/beam/runners/core/DoFnRunners.java  |   2 +-
 .../apache/beam/runners/core/ProcessFnRunner.java  |  10 +-
 .../apache/beam/runners/core/SimpleDoFnRunner.java |   4 +
 ...LifecycleManagerRemovingTransformEvaluator.java |   4 +
 .../direct/ExecutorServiceParallelExecutor.java    |  40 ++++++--
 .../apache/beam/runners/direct/ParDoEvaluator.java |   8 ++
 .../beam/runners/direct/ParDoEvaluatorFactory.java |   2 +-
 .../SplittableProcessElementsEvaluatorFactory.java | 109 ++++++++++-----------
 .../beam/runners/direct/DirectRunnerTest.java      |  35 +++++++
 9 files changed, 147 insertions(+), 67 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
robertwb@apache.org.