diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index 1fd682aebd6ac7899ca0a88f6a4744cd4ebbb006..55f44baa2802d75179e60b6df14796bfe1178e3d 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -2740,7 +2740,11 @@ static void tag_project_function(SQLFunctionCtx *pCtx) {
   
   assert(pCtx->inputBytes == pCtx->outputBytes);
 
-  tVariantDump(&pCtx->tag, pCtx->pOutput, pCtx->outputType, true);
+  if(IS_JSON_DATA_TYPE(pCtx->outputType)) {
+    tVariantDump(&pCtx->tag, pCtx->pOutput, pCtx->outputType, false);
+  }else {
+    tVariantDump(&pCtx->tag, pCtx->pOutput, pCtx->outputType, true);
+  }
   char* data = pCtx->pOutput;
   pCtx->pOutput += pCtx->outputBytes;