fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-09-14 12:22:51 +08:00
parent 3b9ca7b7be
commit 31354d4767
1 changed files with 1 additions and 1 deletions

View File

@ -330,7 +330,7 @@ int32_t doPutDataIntoInputQ(SStreamTask* pTask, int64_t maxVer, int32_t* numOfIt
}
} else {
if (code == TSDB_CODE_OUT_OF_MEMORY) {
tqError("s-task:%s failed to put data into inputQ, since out of memory");
tqError("s-task:%s failed to put data into inputQ, since out of memory", id);
} else {
tqTrace("s-task:%s append input queue failed, code:inputQ is full, ver:%" PRId64, id,
pTask->chkInfo.nextProcessVer);