Repository: incubator-beam Updated Branches: refs/heads/master 1a060f684 -> 31d4bde7a
Fix missing Override Annotations in the DirectRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e37bffc6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e37bffc6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e37bffc6 Branch: refs/heads/master Commit: e37bffc6274d8e33843f66884f0ed58be96c373b Parents: 9d6d622 Author: Thomas Groh <[email protected]> Authored: Wed Jun 29 13:55:53 2016 -0700 Committer: Thomas Groh <[email protected]> Committed: Wed Jun 29 13:56:30 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java | 1 + .../java/org/apache/beam/runners/direct/SideInputContainerTest.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e37bffc6/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java index 9a287b7..b226a2a 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java @@ -241,6 +241,7 @@ class UnboundedReadEvaluatorFactory implements TransformEvaluatorFactory { GlobalWindow.INSTANCE, transform.getOutput().getWindowingStrategy(), new Runnable() { + @Override public void run() { try { mark.finalizeCheckpoint(); http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e37bffc6/runners/direct-java/src/test/java/org/apache/beam/runners/direct/SideInputContainerTest.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/test/java/org/apache/beam/runners/direct/SideInputContainerTest.java b/runners/direct-java/src/test/java/org/apache/beam/runners/direct/SideInputContainerTest.java index c0242ed..ec589da 100644 --- a/runners/direct-java/src/test/java/org/apache/beam/runners/direct/SideInputContainerTest.java +++ b/runners/direct-java/src/test/java/org/apache/beam/runners/direct/SideInputContainerTest.java @@ -483,6 +483,7 @@ public class SideInputContainerTest { Object callback = invocation.getArguments()[3]; final Runnable callbackRunnable = (Runnable) callback; Executors.newSingleThreadExecutor().submit(new Runnable() { + @Override public void run() { try { if (!runLatch.await(1500L, TimeUnit.MILLISECONDS)) {
