diff --git a/cmd/influxd/server_integration_test.go b/cmd/influxd/server_integration_test.go
index a6b612ffc5..644b6e300f 100644
--- a/cmd/influxd/server_integration_test.go
+++ b/cmd/influxd/server_integration_test.go
@@ -543,3 +543,21 @@ func Test_Server5NodeLargeBatchIntegration(t *testing.T) {
 	write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"}))
 	simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize)
 }
+
+func Test_ServerMultiLargeBatchIntegration(t *testing.T) {
+	if testing.Short() {
+		t.Skip()
+	}
+	nNodes := 1
+	nBatches := 5
+	basePort := 8690
+	testName := "single node multi batch"
+	nodes := createCombinedNodeCluster(t, testName, nNodes, basePort)
+
+	createDatabase(t, testName, nodes, "foo")
+	createRetentionPolicy(t, testName, nodes, "foo", "bar")
+	for i := 0; i < nBatches; i++ {
+		write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"}))
+	}
+	simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize*int64(nBatches))
+}