diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index cd9a17081b33582d9123e3eb36bcf46e9177d9e2..3bcc141edc4ba837f2bb88cefdca665423516615 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1329,8 +1329,7 @@ int32_t tqProcessTaskScanHistoryFinishRsp(STQ* pTq, SRpcMsg* pMsg) { } else { tqDebug( "s-task:%s scan-history finish rsp received from downstream task:0x%x, all downstream tasks rsp scan-history " - "completed msg", - pTask->id.idStr); + "completed msg", pTask->id.idStr, req.downstreamId); streamProcessScanHistoryFinishRsp(pTask); }