From a15120f97e6dadf7bdc1e7c2bee80d62ce7547ae Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 27 Nov 2024 10:10:56 +0800 Subject: [PATCH] fix: add failure task destory --- source/libs/qworker/src/qworker.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index 100de805f8..6d91eae4d3 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -231,6 +231,10 @@ int32_t qwExecTask(QW_FPARAMS_DEF, SQWTaskCtx *ctx, bool *queryStop) { _return: taosArrayDestroy(pResList); + + if (TSDB_CODE_SUCCESS != code) { + qwFreeTaskHandle(ctx); + } QW_RET(code); }