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/11/13 18:00:32 UTC

[beam] 01/01: Merge pull request #6973 from robertwb/portable-errors

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 761904cbb763e2f7ecc1d070799e3ea08d931a3e
Merge: ab2642d 368323f
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Tue Nov 13 19:00:25 2018 +0100

    Merge pull request #6973 from robertwb/portable-errors
    
    [BEAM-6008] Propagate errors through portable portable runner.

 .../beam/runners/flink/FlinkJobInvocation.java     | 21 ++++++++++++-
 .../jobsubmission/InMemoryJobService.java          | 21 +++++++++----
 .../runners/portability/flink_runner_test.py       | 14 +++++++++
 .../runners/portability/local_job_service.py       |  1 +
 .../runners/portability/portable_runner.py         | 35 +++++++++++++++++++++-
 .../runners/portability/portable_runner_test.py    | 34 ---------------------
 6 files changed, 84 insertions(+), 42 deletions(-)