diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c index 43dcf2dfa9068059e105bbc2380628e1c5e55fb9..dc4e6f74527c0bac085446b370beefd46fa2bded 100644 --- a/source/common/src/tdatablock.c +++ b/source/common/src/tdatablock.c @@ -1135,6 +1135,7 @@ int32_t colInfoDataEnsureCapacity(SColumnInfoData* pColumn, size_t existRows, ui assert(pColumn->info.bytes); tmp = taosMemoryRealloc(pColumn->pData, numOfRows * pColumn->info.bytes); + memset(tmp, 0, numOfRows * pColumn->info.bytes); if (tmp == NULL) { return TSDB_CODE_OUT_OF_MEMORY; } diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index adf3588bd1966a659749491ca988ea65e0ce85ad..60ee375e2ea2966302f23af41d8858979d355307 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -1311,6 +1311,7 @@ int32_t qwProcessHb(SQWorker *mgmt, SQWMsg *qwMsg, SSchedulerHbReq *req) { if (sch->hbConnInfo.handle) { tmsgReleaseHandle(&sch->hbConnInfo, TAOS_CONN_SERVER); + sch->hbConnInfo.handle = NULL; } memcpy(&sch->hbConnInfo, &qwMsg->connInfo, sizeof(qwMsg->connInfo)); @@ -1331,6 +1332,7 @@ _return: if (code) { tmsgReleaseHandle(&qwMsg->connInfo, TAOS_CONN_SERVER); + qwMsg->connInfo.handle = NULL; } QW_DLOG("hb rsp send, handle:%p, code:%x - %s", qwMsg->connInfo.handle, code, tstrerror(code));