Repository: incubator-beam Updated Branches: refs/heads/master 2b5c6bcb2 -> c584b37b8
Remove unneccssary Assignment in TransformExecutor Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/acf71d31 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/acf71d31 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/acf71d31 Branch: refs/heads/master Commit: acf71d313a43c8f39213ce19277ffebadcc40a77 Parents: 4546fd9 Author: Thomas Groh <[email protected]> Authored: Fri Aug 5 09:59:46 2016 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri Aug 5 10:04:21 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/direct/TransformExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/acf71d31/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java index 3db941d..d873bf5 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java @@ -118,7 +118,7 @@ class TransformExecutor<T> implements Runnable { processElements(evaluator, enforcements); - TransformResult result = finishBundle(evaluator, enforcements); + finishBundle(evaluator, enforcements); } catch (Throwable t) { onComplete.handleThrowable(inputBundle, t); if (t instanceof RuntimeException) {
