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 <[email protected]> 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 [email protected].
