diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index c550b06acb2d7772d0a5745b0856024e9f42bfb3..5c4f4048d13e48e4fb0342c6e9627db8413323da 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -964,7 +964,7 @@ int32_t tqProcessStreamTaskCheckReq(STQ* pTq, SRpcMsg* pMsg) { taskId, rsp.reqId, rsp.upstreamTaskId, rsp.upstreamNodeId, rsp.status); } - return streamSendCheckRsp(pTq->pStreamMeta, &req, &rsp, &pMsg->info, pTask->id.taskId); + return streamSendCheckRsp(pTq->pStreamMeta, &req, &rsp, &pMsg->info, taskId); } int32_t tqProcessStreamTaskCheckRsp(STQ* pTq, int64_t sversion, SRpcMsg* pMsg) { diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c index 06b90d0a516729f77a20c008c81aa828285e557e..4c06b34df456114aacdf720f6a9cf18ca2bb974b 100644 --- a/source/libs/executor/src/executor.c +++ b/source/libs/executor/src/executor.c @@ -122,7 +122,7 @@ void qResetStreamInfoTimeWindow(qTaskInfo_t tinfo) { return; } - qDebug("%s set fill history start key:%"PRId64, GET_TASKID(pTaskInfo), INT64_MIN); + qDebug("%s set fill history start key:%" PRId64, GET_TASKID(pTaskInfo), INT64_MIN); pTaskInfo->streamInfo.fillHistoryWindow.skey = INT64_MIN; } diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index 852622e5a1cf5957c9095781d67b438c2d721160..a39741117c0245f8f6359e698a1a61b8fb339691 100644 --- a/source/libs/stream/src/streamRecover.c +++ b/source/libs/stream/src/streamRecover.c @@ -199,7 +199,7 @@ static void doProcessDownstreamReadyRsp(SStreamTask* pTask, int32_t numOfReqs) { streamTaskSetRangeStreamCalc(pTask); if (status == TASK_STATUS__SCAN_HISTORY) { - qDebug("s-task:%s enter into scan-history-data stage, status:%s", id, numOfReqs, str); + qDebug("s-task:%s enter into scan-history-data stage, status:%s", id, str); streamTaskLaunchScanHistory(pTask); } else { qDebug("s-task:%s downstream tasks are ready, now ready for data from wal, status:%s", id, str);