From df266a5e470e09774a52629c0433679d4d941c81 Mon Sep 17 00:00:00 2001 From: Kenneth Knowles Date: Tue, 14 Jun 2016 16:12:11 -0700 Subject: [PATCH] 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. --- .../beam/runners/direct/ExecutorServiceParallelExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 980d7642abe60..dae9877f64f9f 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 @@ private boolean fireTimers() throws Exception { if (delivery.isEmpty()) { continue; } - KeyedWorkItem work = + KeyedWorkItem work = KeyedWorkItems.timersWorkItem(keyTimers.getKey().getKey(), delivery); @SuppressWarnings({"unchecked", "rawtypes"}) CommittedBundle bundle =