diff --git a/source/libs/function/src/tudf.c b/source/libs/function/src/tudf.c
index 2ade78db40761b625bfb992c5786235a35104460..2269ad7f6a8d5e5d1c67b70be661168907820797 100644
--- a/source/libs/function/src/tudf.c
+++ b/source/libs/function/src/tudf.c
@@ -1400,7 +1400,7 @@ void udfcUvHandleError(SClientUvConn *conn) {
     QUEUE_REMOVE(&task->procTaskQueue);
     uv_sem_post(&task->taskSem);
   }
-  if (!uv_is_closing(conn->pipe)) {
+  if (!uv_is_closing((uv_handle_t *)conn->pipe)) {
     uv_close((uv_handle_t *)conn->pipe, onUdfcPipeClose);
   }
 }
@@ -1554,7 +1554,7 @@ int32_t udfcStartUvTask(SClientUvTaskNode *uvTask) {
       } else {
         SClientUvConn *conn = pipe->data;
         QUEUE_INSERT_TAIL(&conn->taskQueue, &uvTask->connTaskQueue);
-        if (!uv_is_closing(uvTask->pipe)) {
+        if (!uv_is_closing((uv_handle_t *)uvTask->pipe)) {
           uv_close((uv_handle_t *)uvTask->pipe, onUdfcPipeClose);
         }
         code = 0;