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 <[email protected]> Authored: Tue Jun 14 16:12:11 2016 -0700 Committer: Kenneth Knowles <[email protected]> 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 =
