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 <[email protected]> Authored: Wed Jul 19 10:57:40 2017 +0800 Committer: Pei He <[email protected]> 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;
