diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 5d910481c9e4870b77e87aae0ba5f96718c33a15..0ae51284bebf51d1f0470eef9094f7ebd073d1a2 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -6351,6 +6351,11 @@ int32_t createQueryFunc(SQueriedTableInfo* pTableInfo, int32_t numOfOutput, SExp
 
   for (int32_t i = 0; i < numOfOutput; ++i) {
     pExprs[i].base = *pExprMsg[i];
+    memset(pExprs[i].base.param, 0, sizeof(tVariant) * tListLen(pExprs[i].base.param));
+
+    for (int32_t j = 0; j < pExprMsg[i]->numOfParams; ++j) {
+      tVariantAssign(&pExprs[i].base.param[j], &pExprMsg[i]->param[j]);
+    }
 
     int16_t type = 0;
     int16_t bytes = 0;