diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index cbb4b33cf3a236cf87600e47f6090d19e7ec0964..560f92ec4c42508b281beaea950472e43670e3b0 100644
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -16,7 +16,7 @@
 #include "streamInc.h"
 #include "ttimer.h"
 
-#define STREAM_TASK_INPUT_QUEUEU_CAPACITY 102400
+#define STREAM_TASK_INPUT_QUEUEU_CAPACITY 20480
 
 int32_t streamInit() {
   int8_t old;
diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 1122cd8ff0adedaf2fc34e330e6bc6cc3109bbae..663cdb4d7cdf12c33277f8ccf6d481cfe249c304 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 20480
+#define STREAM_EXEC_MAX_BATCH_NUM 10240
 
 bool streamTaskShouldStop(const SStreamStatus* pStatus) {
   int32_t status = atomic_load_8((int8_t*) &pStatus->taskStatus);
diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index c7d85ac8857e65c52396d0eb2f9bac3f02c9e67a..abd14801a81a55fb66c287562552a5c0f4b41c5a 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -24,7 +24,7 @@
 #include "tcompare.h"
 #include "ttimer.h"
 
-#define MAX_TABLE_NAME_NUM 100000
+#define MAX_TABLE_NAME_NUM 2000000
 
 int sessionRangeKeyCmpr(const SSessionKey* pWin1, const SSessionKey* pWin2) {
   if (pWin1->groupId > pWin2->groupId) {