diff --git a/libbeat/publisher/pipeline/output_test.go b/libbeat/publisher/pipeline/output_test.go
index a1549bccb15..5f471ddf396 100644
--- a/libbeat/publisher/pipeline/output_test.go
+++ b/libbeat/publisher/pipeline/output_test.go
@@ -97,7 +97,7 @@ func TestReplaceClientWorker(t *testing.T) {
 			seedPRNG(t)
 
 			err := quick.Check(func(i uint) bool {
-				numBatches := 10000 + (i % 100) // between 1000 and 1099
+				numBatches := 1000 + (i % 100) // between 1000 and 1099
 
 				wqu := makeWorkQueue()
 				retryer := newRetryer(logp.NewLogger("test"), nilObserver, wqu, nil)