You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/06/16 02:35:44 UTC

[1/2] incubator-beam git commit: Fix type error in Eclipse

Repository: incubator-beam
Updated Branches:
  refs/heads/master 518b23c2d -> f8c59bd6c


Fix type error in Eclipse

This type error occurs in my Eclipse installation. It apparently
does not bother the various JDKs we test with. But this is an
accurate typing, so it may help other Eclipse-using contributors,
too.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/df266a5e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/df266a5e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/df266a5e

Branch: refs/heads/master
Commit: df266a5e470e09774a52629c0433679d4d941c81
Parents: c8ad2e7
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Jun 14 16:12:11 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Jun 14 16:12:11 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/ExecutorServiceParallelExecutor.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/df266a5e/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
----------------------------------------------------------------------
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
index 980d764..dae9877 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
@@ -415,7 +415,7 @@ final class ExecutorServiceParallelExecutor implements InProcessExecutor {
               if (delivery.isEmpty()) {
                 continue;
               }
-              KeyedWorkItem<Object, Object> work =
+              KeyedWorkItem<?, Object> work =
                   KeyedWorkItems.timersWorkItem(keyTimers.getKey().getKey(), delivery);
               @SuppressWarnings({"unchecked", "rawtypes"})
               CommittedBundle<?> bundle =


[2/2] incubator-beam git commit: This closes #465

Posted by ke...@apache.org.
This closes #465


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f8c59bd6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f8c59bd6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f8c59bd6

Branch: refs/heads/master
Commit: f8c59bd6cb2d6cf4a4166c7f49c3d3fe4f3653a8
Parents: 518b23c df266a5
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Jun 15 19:33:06 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Jun 15 19:33:06 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/ExecutorServiceParallelExecutor.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f8c59bd6/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
----------------------------------------------------------------------