diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 15a8a9f678096f8525c800e75ace519996493cfe..507783e3cf2f1137541c03d01f1c5c9e3bfef4e3 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -1170,7 +1170,8 @@ void handleDownstreamOperator(SSqlObj** pSqlObjList, int32_t numOfUpstream, SQue
         int32_t numOfFilterCols1 = 0;
         SSingleColumnFilterInfo* pFilterInfo1 = NULL;
         createInputDataFilterInfo(px, numOfCol1, &numOfFilterCols1, &pFilterInfo1);
-
+        
+        pOutput->precision = pSqlObjList[i]->res.precision;
         p[i] = createDummyInputOperator(pSqlObjList[i], pSchema1, n, pFilterInfo1, numOfFilterCols1);
         memcpy(&schema[offset], pSchema1, n * sizeof(SSchema));
         offset += n;
@@ -4570,4 +4571,4 @@ SNewVgroupInfo createNewVgroupInfo(SVgroupMsg *pVgroupMsg) {
   }
 
   return info;
-}
\ No newline at end of file
+}