diff --git a/tests/system-test/7-tmq/subscribeStb0.py b/tests/system-test/7-tmq/subscribeStb0.py
index 9aebf54cfe13b16ba908b77d48c8a1916542877f..b6a9934d4f43cd4d4cd141d6e701c3c96e42daea 100644
--- a/tests/system-test/7-tmq/subscribeStb0.py
+++ b/tests/system-test/7-tmq/subscribeStb0.py
@@ -408,7 +408,7 @@ class TDTestCase:
                 
         remaindrowcnt = parameterDict["rowsPerTbl"] * (parameterDict["ctbNum"] - dropTblNum)
 
-        if not (totalConsumeRows < expectrowcnt and totalConsumeRows > remaindrowcnt):
+        if not (totalConsumeRows <= expectrowcnt and totalConsumeRows >= remaindrowcnt):
             tdLog.info("act consume rows: %d, expect consume rows: between %d and %d"%(totalConsumeRows, remaindrowcnt, expectrowcnt))
             tdLog.exit("tmq consume rows error!")