From 08be4503c938f47a89c791d4de42aba23f3828ed Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Wed, 16 Nov 2022 16:25:58 +0800
Subject: [PATCH] fix: fix query thread stop issue

---
 source/libs/qworker/src/qworker.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c
index e45beb7e13..4caa266d8a 100644
--- a/source/libs/qworker/src/qworker.c
+++ b/source/libs/qworker/src/qworker.c
@@ -1191,6 +1191,8 @@ void qWorkerStopAllTasks(void *qWorkerMgmt) {
     
     if (QW_QUERY_RUNNING(ctx)) {
       qwKillTaskHandle(ctx);
+    } else if (!QW_EVENT_PROCESSED(ctx, QW_EVENT_DROP)) {
+      QW_SET_EVENT_RECEIVED(ctx, QW_EVENT_DROP);
     }
 
     QW_UNLOCK(QW_WRITE, &ctx->lock);
-- 
GitLab