Repository: incubator-beam Updated Branches: refs/heads/master 7f562cc10 -> a18c27488
[BEAM-595] avoid throwing Exception in waitUntilFinish in SparkRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c92f9861 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c92f9861 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c92f9861 Branch: refs/heads/master Commit: c92f9861bad7f3352294cc2eb062f1e48be18445 Parents: b8e6eea Author: Pei He <pe...@google.com> Authored: Thu Oct 13 14:14:15 2016 -0700 Committer: Pei He <pe...@google.com> Committed: Mon Oct 17 11:43:04 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/spark/translation/EvaluationContext.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c92f9861/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java index 317c7be..83ef3c5 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java @@ -309,7 +309,9 @@ public class EvaluationContext implements EvaluationResult { @Override public State waitUntilFinish(Duration duration) throws IOException, InterruptedException { - throw new UnsupportedOperationException( - "Spark runner EvaluationContext does not support waitUntilFinish."); + // This is no-op, since Spark runner is blocking. + // It needs to be updated once SparkRunner supports non-blocking execution: + // https://issues.apache.org/jira/browse/BEAM-595 + return State.DONE; } }
