From ebf9a13fe756585a4a82716079e6389aa3d21917 Mon Sep 17 00:00:00 2001 From: jiajingbin Date: Thu, 27 Apr 2023 18:14:46 +0800 Subject: [PATCH] inc batch num --- source/libs/stream/src/streamExec.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index e1488a8a6f..c71bff24bf 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);