From 482eab9666ea91bc11fd4dd16a004c1fd9239bb9 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 6 Sep 2024 13:45:15 +0800 Subject: [PATCH] refactor: adjust log. --- source/libs/executor/src/sortoperator.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/source/libs/executor/src/sortoperator.c b/source/libs/executor/src/sortoperator.c index bd67c4821d..822faedb25 100644 --- a/source/libs/executor/src/sortoperator.c +++ b/source/libs/executor/src/sortoperator.c @@ -355,8 +355,9 @@ int32_t doOpenSortOperator(SOperatorInfo* pOperator) { pInfo->startTs = taosGetTimestampUs(); // pInfo->binfo.pRes is not equalled to the input datablock. pInfo->pSortHandle = NULL; - int32_t code = tsortCreateSortHandle(pInfo->pSortInfo, SORT_SINGLESOURCE_SORT, -1, -1, NULL, pTaskInfo->id.str, - pInfo->maxRows, pInfo->maxTupleLength, tsPQSortMemThreshold * 1024 * 1024, &pInfo->pSortHandle); + int32_t code = + tsortCreateSortHandle(pInfo->pSortInfo, SORT_SINGLESOURCE_SORT, -1, -1, NULL, pTaskInfo->id.str, pInfo->maxRows, + pInfo->maxTupleLength, tsPQSortMemThreshold * 1024 * 1024, &pInfo->pSortHandle); if (code) { return code; } @@ -365,10 +366,10 @@ int32_t doOpenSortOperator(SOperatorInfo* pOperator) { SSortSource* pSource = taosMemoryCalloc(1, sizeof(SSortSource)); if (pSource == NULL) { - qInfo("alloc:%p", pSource); return terrno; } + qInfo("---alloc:%p", pSource); pSource->param = pOperator->pDownstream[0]; pSource->onlyRef = true;