diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 5d3c1ac9efa39c1191a90f5d1e22d56c3b400847..de0d57fc79d71f9b86c94b47937ec158aff60ae6 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -777,7 +777,6 @@ static void setResRawPtrImpl(SSqlRes* pRes, SInternalField* pInfo, int32_t i, bo
               tscError("charset:%s to %s. val:%s convert failed.", DEFAULT_UNICODE_ENCODEC, tsCharset, (char*)p);
             }
           }
-          return;
         }else if (type == TSDB_DATA_TYPE_DOUBLE) {
           double jsonVd = *(double*)(realData);
           sprintf(varDataVal(dst), "%.9lf", jsonVd);
diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index bfdc23154c4fa916036b87c6b4d59b02fd7b6c87..38c9dd531b18dfe14aab582f9aecc5080c00cfef 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -3401,7 +3401,7 @@ static void doSetTagValueInParam(void* pTable, char* param, int32_t paramLen, in
     }else{
       getJsonTagValueAll(val, jsonVal, TSDB_MAX_JSON_TAGS_LEN);
     }
-    tVariantCreateFromBinary(tag, jsonVal, varDataTLen(jsonVal), type);
+    tVariantCreateFromBinary(tag, jsonVal, CHAR_BYTES + varDataTLen(POINTER_SHIFT(jsonVal,CHAR_BYTES)), type);
   } else {
     tVariantCreateFromBinary(tag, val, bytes, type);
   }