diff --git a/source/util/src/tworker.c b/source/util/src/tworker.c
index c4b3271c65..3e591c7d7f 100644
--- a/source/util/src/tworker.c
+++ b/source/util/src/tworker.c
@@ -89,7 +89,7 @@ static void *tQWorkerThreadFp(SQueueWorker *worker) {
     if (qinfo.timestamp != 0) {
       int64_t cost = taosGetTimestampUs() - qinfo.timestamp;
       if (cost > QUEUE_THRESHOLD) {
-        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost);
+        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost / QUEUE_THRESHOLD);
       }
     }
 
@@ -210,7 +210,7 @@ static void *tAutoQWorkerThreadFp(SQueueWorker *worker) {
     if (qinfo.timestamp != 0) {
       int64_t cost = taosGetTimestampUs() - qinfo.timestamp;
       if (cost > QUEUE_THRESHOLD) {
-        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost);
+        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost / QUEUE_THRESHOLD);
       }
     }
 
@@ -357,7 +357,7 @@ static void *tWWorkerThreadFp(SWWorker *worker) {
     if (qinfo.timestamp != 0) {
       int64_t cost = taosGetTimestampUs() - qinfo.timestamp;
       if (cost > QUEUE_THRESHOLD) {
-        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost);
+        uWarn("worker:%s,message has been queued for too long, cost: %" PRId64 "s", pool->name, cost / QUEUE_THRESHOLD);
       }
     }