fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-08-30 09:06:45 +08:00
parent fb8867f403
commit da1bdd689f
1 changed files with 1 additions and 1 deletions

View File

@ -133,7 +133,7 @@ void streamTaskExecImpl(SStreamTask* pTask, SStreamQueueItem* pItem, int64_t* to
const SStreamDataBlock* pRetrieveBlock = (const SStreamDataBlock*)pItem;
int32_t num = taosArrayGetSize(pRetrieveBlock->blocks);
if (num != 1) {
stError("s-task:%s invalid retrieve block, ignore", pTask->id.idStr, num);
stError("s-task:%s invalid retrieve block number:%d, ignore", pTask->id.idStr, num);
continue;
}