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);
 }