From f0f90888abc85c5013830103c655663fcb19a055 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 11 May 2023 13:48:50 +0800 Subject: [PATCH] refactor: update some logs. --- source/dnode/vnode/src/tq/tqRead.c | 4 ++-- source/dnode/vnode/src/tq/tqUtil.c | 2 +- source/libs/executor/src/scanoperator.c | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c index af3969cc29..773fc0e1af 100644 --- a/source/dnode/vnode/src/tq/tqRead.c +++ b/source/dnode/vnode/src/tq/tqRead.c @@ -672,8 +672,8 @@ int32_t tqRetrieveDataBlock(STqReader* pReader, const char* idstr) { SColVal colVal; tRowGet(pRow, pTSchema, sourceIdx, &colVal); if (colVal.cid < pColData->info.colId) { - tqDebug("colIndex:%d column id:%d in row, ignore, the required colId:%d, total cols in schema:%d", - sourceIdx, colVal.cid, pColData->info.colId, pTSchema->numOfCols); +// tqDebug("colIndex:%d column id:%d in row, ignore, the required colId:%d, total cols in schema:%d", +// sourceIdx, colVal.cid, pColData->info.colId, pTSchema->numOfCols); sourceIdx++; continue; } else if (colVal.cid == pColData->info.colId) { diff --git a/source/dnode/vnode/src/tq/tqUtil.c b/source/dnode/vnode/src/tq/tqUtil.c index a66d63a910..051efccc4f 100644 --- a/source/dnode/vnode/src/tq/tqUtil.c +++ b/source/dnode/vnode/src/tq/tqUtil.c @@ -21,7 +21,7 @@ static int32_t tqSendMetaPollRsp(STQ* pTq, const SRpcMsg* pMsg, const SMqPollReq char* createStreamTaskIdStr(int64_t streamId, int32_t taskId) { char buf[128] = {0}; - sprintf(buf, "0x%" PRIx64 "-%d", streamId, taskId); + sprintf(buf, "0x%" PRIx64 "-0x%x", streamId, taskId); return taosStrdup(buf); } diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 0508d70661..b818e35e64 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -2110,7 +2110,7 @@ FETCH_NEXT_BLOCK: pInfo->numOfExec++; pOperator->resultInfo.totalRows += pBlockInfo->rows; - qDebug("scan rows: %" PRId64, pBlockInfo->rows); + qDebug("scan rows: %" PRId64", %s", pBlockInfo->rows, pTaskInfo->id.str); if (pBlockInfo->rows > 0) { return pInfo->pRes; }