diff --git a/tests/system-test/7-tmq/tmq3mnodeSwitch.py b/tests/system-test/7-tmq/tmq3mnodeSwitch.py
index 9ded8fc942316915c377a356cde11b5e9db08e34..7c95f7a3dbd1983c1c1ecd7e910c152eac6ca477 100644
--- a/tests/system-test/7-tmq/tmq3mnodeSwitch.py
+++ b/tests/system-test/7-tmq/tmq3mnodeSwitch.py
@@ -252,7 +252,7 @@ class TDTestCase:
         resultList = tmqCom.selectConsumeResult(expectRows)
 
         tdLog.info("expect consume rows: %d should less/equal than act consume rows: %d"%(expectRowsList[0], resultList[0]))
-        if expectRowsList[0] <= resultList[0]:
+        if expectRowsList[0] > resultList[0]:
             tdLog.exit("0 tmq consume rows error!")
 
         if expectRowsList[0] == resultList[0]: