diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index e1488a8a6f2636e38115e94aac93903c32c134a0..c71bff24bf19ba2c4f5ffddbf7ae1adfe19adbee 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -15,7 +15,7 @@
 
 #include "streamInc.h"
 
-#define STREAM_EXEC_MAX_BATCH_NUM 4096
+#define STREAM_EXEC_MAX_BATCH_NUM 20480
 
 bool streamTaskShouldStop(const SStreamStatus* pStatus) {
   int32_t status = atomic_load_8((int8_t*) &pStatus->taskStatus);