diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 5b363d96de..1426ac01fc 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -35,10 +35,10 @@
     if(!tDecodeIsEnd(&decoder)){                                 \
       if(tDecodeI32(&decoder, &pReq->sqlLen) < 0) return -1;    \
       if(pReq->sqlLen > 0){                                     \
+        if (tDecodeBinaryAlloc(&decoder, (void **)&pReq->sql, NULL) < 0) return -1;  \
       }                                                         \
     }                                                           \
   } while (0)
-//        if (tDecodeBinaryAlloc(&decoder, (void **)&pReq->sql, NULL) < 0) return -1;  \
 
 #define ENCODESQL()                                              \
   do {                                                           \