diff --git a/core/pipeline/Pipeline.cpp b/core/pipeline/Pipeline.cpp index 3025870e5a..a36f743e3c 100644 --- a/core/pipeline/Pipeline.cpp +++ b/core/pipeline/Pipeline.cpp @@ -291,7 +291,7 @@ bool Pipeline::Init(PipelineConfig&& config) { ProcessQueueManager::GetInstance()->CreateOrUpdateBoundedQueue(mContext.GetProcessQueueKey(), priority); } else { ProcessQueueManager::GetInstance()->CreateOrUpdateCircularQueue( - mContext.GetProcessQueueKey(), priority, 5000000); + mContext.GetProcessQueueKey(), priority, 1024); }