diff --git a/source/libs/function/src/tudf.c b/source/libs/function/src/tudf.c
index 1f531be1f62b8b209b4907a93bd757fe50a21b1f..0cc5b1f92d589bc9f2170b71fd623cfa9f5400b7 100644
--- a/source/libs/function/src/tudf.c
+++ b/source/libs/function/src/tudf.c
@@ -290,6 +290,7 @@ int32_t encodeRequest(char **pBuf, int32_t *pBufLen, SUdfRequest *request) {
   *(int32_t *) bufBegin = request->msgLen;
   *pBuf = bufBegin;
   *pBufLen = request->msgLen;
+  debugPrint("\tLen: estimate: %d, actual:%d", len, *pBufLen);
   return 0;
 }
 
@@ -932,9 +933,9 @@ int32_t stopUdfService() {
     uv_process_kill(&gUdfdProcess, SIGINT);
   }
   uv_async_send(&gUdfLoopStopAsync);
-  uv_mutex_destroy(&gUdfTaskQueueMutex);
   uv_thread_join(&gUdfLoopThread);
-  return 0;  gUdfcState = UDFC_STATUS_FINAL;
+  uv_mutex_destroy(&gUdfTaskQueueMutex);
+  gUdfcState = UDFC_STATUS_FINAL;
   return 0;
 }
 
diff --git a/source/libs/function/src/udfd.c b/source/libs/function/src/udfd.c
index b473f060c099c1277e6c92752980e8c2e6a7bed6..2d9344709a8a281f9c1eb4a1d19af354390eff61 100644
--- a/source/libs/function/src/udfd.c
+++ b/source/libs/function/src/udfd.c
@@ -181,7 +181,7 @@ void udfdProcessRequest(uv_work_t *req) {
 }
 
 void udfdOnWrite(uv_write_t *req, int status) {
-    debugPrint("%s", "after writing to pipe");
+    debugPrint("%s", "server after writing to pipe");
     if (status < 0) {
         debugPrint("Write error %s", uv_err_name(status));
     }
@@ -205,7 +205,7 @@ void udfdSendResponse(uv_work_t *work, int status) {
 }
 
 void udfdAllocBuffer(uv_handle_t *handle, size_t suggestedSize, uv_buf_t *buf) {
-    debugPrint("%s", "allocate buffer for read");
+    debugPrint("%s", "server allocate buffer for read");
     SUdfdUvConn *ctx = handle->data;
     int32_t msgHeadSize = sizeof(int32_t) + sizeof(int64_t);
     if (ctx->inputCap == 0) {