From cb218d674a62d41ba12b9a1493dfb1ea63d1b497 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 26 Sep 2024 01:13:01 +0000 Subject: [PATCH 1/2] fix/TD-32321-add-log --- source/libs/qworker/src/qworker.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index e08868d7c1..ee7c51560b 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -1428,6 +1428,7 @@ void qWorkerDestroy(void **qWorkerMgmt) { return; } + qInfo("wait for destroyed, refId:%" PRIx64, mgmt->refId); while (0 == destroyed) { taosMsleep(2); } From 2c244979a18f85e3603a4dc7c83d353c00ce18d8 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 26 Sep 2024 03:52:07 +0000 Subject: [PATCH 2/2] fix/TD-32321-add-log-fix-case --- source/libs/qworker/src/qworker.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index ee7c51560b..7180c58404 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -1428,7 +1428,7 @@ void qWorkerDestroy(void **qWorkerMgmt) { return; } - qInfo("wait for destroyed, refId:%" PRIx64, mgmt->refId); + qInfo("wait for destroyed"); while (0 == destroyed) { taosMsleep(2); }