diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 859c487faf..b449a973da 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -937,6 +937,7 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) { pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pStateTask, false, -1, -1); if (pTask->pState == NULL) { + tqError("s-task:%s (vgId:%d) failed to open state for task", pTask->id.idStr, vgId); return -1; }