diff --git a/src/main/java/net/helenus/core/operation/BatchOperation.java b/src/main/java/net/helenus/core/operation/BatchOperation.java
index 13685a4..41763ec 100644
--- a/src/main/java/net/helenus/core/operation/BatchOperation.java
+++ b/src/main/java/net/helenus/core/operation/BatchOperation.java
@@ -29,12 +29,13 @@ import net.helenus.core.UnitOfWork;
 import net.helenus.support.HelenusException;
 
 public class BatchOperation extends Operation<Long> {
-  private BatchStatement batch = null;
+  private final BatchStatement batch;
   private List<AbstractOperation<?, ?>> operations = new ArrayList<AbstractOperation<?, ?>>();
   private boolean logged = true;
 
   public BatchOperation(AbstractSessionOperations sessionOperations) {
     super(sessionOperations);
+      batch = new BatchStatement();
   }
 
   public void add(AbstractOperation<?, ?> operation) {
@@ -43,7 +44,6 @@ public class BatchOperation extends Operation<Long> {
 
   @Override
   public BatchStatement buildStatement(boolean cached) {
-    batch = new BatchStatement();
     batch.addAll(
         operations.stream().map(o -> o.buildStatement(cached)).collect(Collectors.toList()));
     batch.setConsistencyLevel(sessionOps.getDefaultConsistencyLevel());