diff --git a/source/util/src/tprocess.c b/source/util/src/tprocess.c
index 139c35de45..cacedce857 100644
--- a/source/util/src/tprocess.c
+++ b/source/util/src/tprocess.c
@@ -392,7 +392,7 @@ static void taosProcThreadLoop(SProcObj *pProc) {
       uDebug("proc:%s, get no msg from queue:%p and exit the proc thread", pProc->name, pQueue);
       break;
     } else if (numOfMsgs < 0) {
-      uTrace("proc:%s, get no msg from queue:%p since %s", pProc->name, pQueue, terrstr());
+      uError("proc:%s, get no msg from queue:%p since %s", pProc->name, pQueue, terrstr());
       taosMsleep(1);
       continue;
     } else {
@@ -470,7 +470,10 @@ void taosProcCloseHandles(SProcObj *pProc, void (*HandleFp)(void *handle)) {
 
 void taosProcPutToParentQ(SProcObj *pProc, const void *pHead, int16_t headLen, const void *pBody, int32_t bodyLen,
                           ProcFuncType ftype) {
+  int32_t retry = 0;
   while (taosProcQueuePush(pProc, pProc->pParentQueue, pHead, headLen, pBody, bodyLen, 0, ftype) != 0) {
-    taosMsleep(1);
+    uInfo("proc:%s, failed to put msg to queue:%p since %s, retry:%d", pProc->name, pProc->pParentQueue, terrstr(), retry);
+    retry++;
+    taosMsleep(retry);
   }
 }
diff --git a/source/util/test/CMakeLists.txt b/source/util/test/CMakeLists.txt
index d6b779b6e3..0d990204d2 100644
--- a/source/util/test/CMakeLists.txt
+++ b/source/util/test/CMakeLists.txt
@@ -46,11 +46,11 @@ add_executable(encodeTest "encodeTest.cpp")
 target_link_libraries(encodeTest os util gtest gtest_main)
 
 # queueTest
-add_executable(queue_test "queueTest.cpp")
-target_link_libraries(queue_test os util gtest_main)   
+add_executable(proc_test "procTest.cpp")
+target_link_libraries(proc_test os util gtest_main)   
 add_test(
-    NAME queue_test
-    COMMAND queue_test
+    NAME proc_test
+    COMMAND proc_test
 )
 
 # cfgTest
diff --git a/source/util/test/queueTest.cpp b/source/util/test/procTest.cpp
similarity index 100%
rename from source/util/test/queueTest.cpp
rename to source/util/test/procTest.cpp