You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/07/06 17:20:38 UTC
[32/50] [abbrv] incubator-beam git commit: Fix missing Override
Annotations in the DirectRunner
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/8f7e24a2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8f7e24a2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8f7e24a2
Branch: refs/heads/runners-spark2
Commit: 8f7e24a2222754054be01e4c78205fedf14d11ac
Parents: 1779bf8
Author: Thomas Groh <tg...@google.com>
Authored: Wed Jun 29 13:55:53 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Jul 6 10:18:52 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/8f7e24a2/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/8f7e24a2/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)) {