diff --git a/lib/query-stream.js b/lib/query-stream.js
index e146e02..8c7919e 100644
--- a/lib/query-stream.js
+++ b/lib/query-stream.js
@@ -14,8 +14,7 @@ class QueryStream extends Readable {
     if (!opts.concurrency) opts.concurrency = opts.highWaterMark || node.concurrency
 
     super({
-      objectMode: true,
-      highWaterMark: opts.concurrency
+      objectMode: true
     })
 
     const cmd = node._commands.get(command)