src/main/java/org/embulk/output/multi/TransactionalPageOutputDelegate.java in embulk-output-multi-0.2.0 vs src/main/java/org/embulk/output/multi/TransactionalPageOutputDelegate.java in embulk-output-multi-0.2.1

@@ -80,11 +80,10 @@
 
     private class Worker implements Callable<TaskReport> {
         @Override
         public TaskReport call() throws InterruptedException {
             while (true) {
-                final Supplier<Object> task = taskQueue.take();
-                final Object result = task.get();
+                final Object result = taskQueue.take().get();
                 if (result instanceof TaskReport) {
                     return (TaskReport) result;
                 }
             }
         }