opt batch num

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;

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);

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) {