diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 7b10a1fc99..0fb78fb589 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -15,7 +15,8 @@ #include "streamInc.h" -#define MAX_STREAM_EXEC_BATCH_NUM 10240 +// maximum allowed processed block batches. One block may include several submit blocks +#define MAX_STREAM_EXEC_BATCH_NUM 128 #define MIN_STREAM_EXEC_BATCH_NUM 16 bool streamTaskShouldStop(const SStreamStatus* pStatus) { @@ -297,6 +298,7 @@ int32_t streamExecForAll(SStreamTask* pTask) { pInput = newRet; streamQueueProcessSuccess(pTask->inputQueue); if (batchSize > MAX_STREAM_EXEC_BATCH_NUM) { + qDebug("maximum batch limit:%d reached, processing, %s", MAX_STREAM_EXEC_BATCH_NUM, pTask->id.idStr); break; } }