未验证 提交 dac8b460 编写于 作者: H Haojun Liao 提交者: GitHub

Merge pull request #20039 from taosdata/fix/TD-22549

fix:add limit for stream batch
...@@ -15,6 +15,8 @@ ...@@ -15,6 +15,8 @@
#include "streamInc.h" #include "streamInc.h"
#define STREAM_EXEC_MAX_BATCH_NUM 100
static int32_t streamTaskExecImpl(SStreamTask* pTask, const void* data, SArray* pRes) { static int32_t streamTaskExecImpl(SStreamTask* pTask, const void* data, SArray* pRes) {
int32_t code; int32_t code;
void* exec = pTask->exec.executor; void* exec = pTask->exec.executor;
...@@ -221,6 +223,9 @@ int32_t streamExecForAll(SStreamTask* pTask) { ...@@ -221,6 +223,9 @@ int32_t streamExecForAll(SStreamTask* pTask) {
batchCnt++; batchCnt++;
input = newRet; input = newRet;
streamQueueProcessSuccess(pTask->inputQueue); streamQueueProcessSuccess(pTask->inputQueue);
if (batchCnt > STREAM_EXEC_MAX_BATCH_NUM) {
break;
}
} }
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册