From 74ab6897190a7b4819e638056032461aec89a3b4 Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Fri, 5 May 2023 08:59:07 +0800
Subject: [PATCH] opt batch num

---
 source/libs/stream/src/stream.c      | 2 +-
 source/libs/stream/src/streamExec.c  | 2 +-
 source/libs/stream/src/streamState.c | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index cbb4b33cf3..560f92ec4c 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 1122cd8ff0..663cdb4d7c 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 c7d85ac885..abd14801a8 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) {