diff --git a/src/main/java/org/influxdb/impl/BatchProcessor.java b/src/main/java/org/influxdb/impl/BatchProcessor.java
index fb3328da6..e6f5eae12 100644
--- a/src/main/java/org/influxdb/impl/BatchProcessor.java
+++ b/src/main/java/org/influxdb/impl/BatchProcessor.java
@@ -176,7 +176,12 @@ void write() {
 	void put(final BatchEntry batchEntry) {
 		this.queue.add(batchEntry);
 		if (this.queue.size() >= this.actions) {
-			write();
+			this.scheduler.submit(new Runnable() {
+				@Override
+				public void run() {
+					write();
+				}
+			});
 		}
 	}