This is an automated email from the ASF dual-hosted git repository. jbonofre pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 50139b43bbbb95584513099094445f57c495b515 Merge: a2a5d3d 124ead5 Author: Jean-Baptiste Onofré <[email protected]> AuthorDate: Thu Apr 5 06:09:24 2018 +0200 Merge pull request #4790 from rmannibucau/fix/BEAM-3409_wait-for-teardown-execution-in-direct-runner [BEAM-3409] waitUntilFinish() doesn't wait for the teardown execution on Direct runner - fixing compilation issue on flink .../org/apache/beam/runners/core/DoFnRunner.java | 6 ++ .../runners/core/LateDataDroppingDoFnRunner.java | 5 ++ .../apache/beam/runners/core/ProcessFnRunner.java | 6 ++ .../runners/core/PushbackSideInputDoFnRunner.java | 6 ++ .../apache/beam/runners/core/SimpleDoFnRunner.java | 5 ++ .../core/SimplePushbackSideInputDoFnRunner.java | 8 +- .../beam/runners/core/StatefulDoFnRunner.java | 5 ++ .../SimplePushbackSideInputDoFnRunnerTest.java | 6 ++ ...LifecycleManagerRemovingTransformEvaluator.java | 4 + .../direct/ExecutorServiceParallelExecutor.java | 42 ++++++++-- .../apache/beam/runners/direct/ParDoEvaluator.java | 8 ++ .../SplittableProcessElementsEvaluatorFactory.java | 95 +++++++++++----------- .../beam/runners/direct/DirectRunnerTest.java | 35 ++++++++ .../flink/metrics/DoFnRunnerWithMetricsUpdate.java | 6 ++ .../spark/translation/DoFnRunnerWithMetrics.java | 6 ++ .../apache/beam/fn/harness/FnApiDoFnRunner.java | 5 ++ 16 files changed, 193 insertions(+), 55 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
