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/cfa217a8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cfa217a8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cfa217a8

Branch: refs/heads/python-sdk
Commit: cfa217a894575f392f1dfe1612e10e393df5c7ab
Parents: babddbb
Author: Kenneth Knowles <k...@google.com>
Authored: Tue Jun 14 16:12:11 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Mon Jun 20 15:14:29 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/cfa217a8/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 4bb5021..78f3fe4 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 
PipelineExecutor {
               if (delivery.isEmpty()) {
                 continue;
               }
-              KeyedWorkItem<Object, Object> work =
+              KeyedWorkItem<?, Object> work =
                   KeyedWorkItems.timersWorkItem(keyTimers.getKey().getKey(), 
delivery);
               @SuppressWarnings({"unchecked", "rawtypes"})
               CommittedBundle<?> bundle =

Reply via email to