You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pe...@apache.org on 2017/08/20 15:03:38 UTC
[38/53] [abbrv] beam git commit: jstorm-runner: minor update for
exception handling of TestJStormRunner
jstorm-runner: minor update for exception handling of TestJStormRunner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ad046483
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ad046483
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ad046483
Branch: refs/heads/jstorm-runner
Commit: ad046483e6d2341a4a2156e0db15f213c7f7feea
Parents: 1819833
Author: basti.lj <ba...@alibaba-inc.com>
Authored: Wed Jul 19 10:57:40 2017 +0800
Committer: Pei He <pe...@apache.org>
Committed: Sat Aug 19 12:02:59 2017 +0800
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/ad046483/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java
----------------------------------------------------------------------
diff --git a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java
index 0088cf9..3124da2 100644
--- a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java
+++ b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/TestJStormRunner.java
@@ -67,7 +67,7 @@ public class TestJStormRunner extends PipelineRunner<JStormRunnerResult> {
throw new AssertionError("Failed assertion checks.");
} else if (taskExceptionRec != null) {
LOG.info("Exception was found.", taskExceptionRec);
- throw new AssertionError(taskExceptionRec.getCause());
+ throw new RuntimeException(taskExceptionRec.getCause());
} else {
JStormUtils.sleepMs(500);
waitTime += 500;