diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 0f5e607e2259a02656f60d48dddcd18761a3fc44..858be75911ab2254bb70942a95eea7ee9b018bc7 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -2187,6 +2187,8 @@ SSqlObj* createSubqueryObj(SSqlObj* pSql, int16_t tableIndex, __async_cb_func_t
   pnCmd->tagData.data = NULL;
   pnCmd->tagData.dataLen = 0;
 
+  pnCmd->pUdfInfo = taosArrayDup(pCmd->pUdfInfo);
+
   if (tscAddSubqueryInfo(pnCmd) != TSDB_CODE_SUCCESS) {
     terrno = TSDB_CODE_TSC_OUT_OF_MEMORY;
     goto _error;