1 files changed, 1 insertions, 2 deletions
diff --git a/src/main/java/com/zdjizhi/etl/CKBatchWindow.java b/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
index f66455f..947bad8 100644
--- a/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
+++ b/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
@@ -16,8 +16,7 @@ public class CKBatchWindow implements AllWindowFunction<Map<String, Object>, Lis
         Iterator<Map<String, Object>> iterator = iterable.iterator();
         List<Map<String, Object>> batchLog = new ArrayList<>();
         while (iterator.hasNext()) {
-            Map<String, Object> next = iterator.next();
-            batchLog.add(next);
+            batchLog.add(iterator.next());
         }
         out.collect(batchLog);
     }