enh: add err msg

This commit is contained in:
yihaoDeng 2022-09-13 14:30:51 +08:00
parent f72668def8
commit e979129669
1 changed files with 0 additions and 1 deletions

View File

@ -2001,7 +2001,6 @@ void ctgCleanupCacheQueue(void) {
ctgDebug("process [%s] operation", gCtgCacheOperation[op->opId].name); ctgDebug("process [%s] operation", gCtgCacheOperation[op->opId].name);
(*gCtgCacheOperation[op->opId].func)(op); (*gCtgCacheOperation[op->opId].func)(op);
stopQueue = true; stopQueue = true;
taosMemoryFree(op->data);
CTG_RT_STAT_INC(numOfOpDequeue, 1); CTG_RT_STAT_INC(numOfOpDequeue, 1);
} else { } else {
taosMemoryFree(op->data); taosMemoryFree(op->data);