diff --git a/tests/system-test/7-tmq/tmqCommon.py b/tests/system-test/7-tmq/tmqCommon.py
index d17fea7b5aee37fb8e04c1bf7e7fffdc46723559..b47601620a6d91fb4c8a7ebf24d5adc44180a726 100644
--- a/tests/system-test/7-tmq/tmqCommon.py
+++ b/tests/system-test/7-tmq/tmqCommon.py
@@ -468,10 +468,12 @@ class TMQCom:
             dstSplit = dst.split(',')
             srcSplit = src.split(',')
 
-            if len(dstSplit) != len(srcSplit):
-                tdLog.exit("consumerId %d consume rows len is not match the rows by direct query"%consumerId)
             if not dst or not src:
                 break
+            if len(dstSplit) != len(srcSplit):
+                tdLog.exit("consumerId %d consume rows len is not match the rows by direct query,len(dstSplit):%d != len(srcSplit):%d, dst:%s, src:%s"
+                           %(consumerId, len(dstSplit), len(srcSplit), dst, src))
+
             for i in range(len(dstSplit)):
                 if srcSplit[i] != dstSplit[i]:
                     srcFloat = float(srcSplit[i])