diff --git a/include/MySQL_Data_Stream.h b/include/MySQL_Data_Stream.h
index c1fb3588c..c0d0bb6b3 100644
--- a/include/MySQL_Data_Stream.h
+++ b/include/MySQL_Data_Stream.h
@@ -5,7 +5,7 @@
 #include "cpp.h"
 
 
-#define QUEUE_T_DEFAULT_SIZE	8192
+#define QUEUE_T_DEFAULT_SIZE	32768
 
 typedef struct _queue_t {
     void *buffer;