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 =