diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index fd8729e37925647279648ebd1bc4eadbdfa7feef..23aa4d02b27d5a4264957db07315cf98609fbd87 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -237,7 +237,7 @@ int32_t getResultDataInfo(int32_t dataType, int32_t dataBytes, int32_t functionI
 
   if (isSuperTable) {
     if (functionId < 0) {
-      if (pUdfInfo->bufSize > 0) {
+      if (pUdfInfo->bufSize > 0 && pUdfInfo->funcType == TSDB_UDF_TYPE_AGGREGATE) {
         *type = TSDB_DATA_TYPE_BINARY;
         *bytes = pUdfInfo->bufSize;
         *interBytes = *bytes;