beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bchamb...@apache.org
Subject [1/2] incubator-beam git commit: Wrap Exceptions thrown in StartBundle in the InProcessPipelineRunner
Date Thu, 21 Apr 2016 23:03:00 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master c3567f1e7 -> 6dd5d7041


Wrap Exceptions thrown in StartBundle in the InProcessPipelineRunner


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8ebb51c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a8ebb51c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a8ebb51c

Branch: refs/heads/master
Commit: a8ebb51c3b34b944ea13bcb0921e04b01da8a7ba
Parents: c3567f1
Author: Thomas Groh <tgroh@google.com>
Authored: Thu Apr 21 10:51:20 2016 -0700
Committer: bchambers <bchambers@google.com>
Committed: Thu Apr 21 15:48:23 2016 -0700

----------------------------------------------------------------------
 .../beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a8ebb51c/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java
b/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java
index 9840e06..35639bd 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/ParDoInProcessEvaluator.java
@@ -77,7 +77,11 @@ class ParDoInProcessEvaluator<T> implements TransformEvaluator<T>
{
             counters.getAddCounterMutator(),
             application.getInput().getWindowingStrategy());
 
-    runner.startBundle();
+    try {
+      runner.startBundle();
+    } catch (Exception e) {
+      throw UserCodeException.wrap(e);
+    }
 
     return new ParDoInProcessEvaluator<>(
         runner, application, counters, outputBundles.values(), stepContext);


Mime
View raw message