diff --git a/tests/system-test/2-query/join.py b/tests/system-test/2-query/join.py
index b5e57f0b4b..42265e6002 100644
--- a/tests/system-test/2-query/join.py
+++ b/tests/system-test/2-query/join.py
@@ -150,9 +150,10 @@ class TDTestCase:
 
     def __join_check(self,):
         tdLog.printNoPrefix("==========current sql condition check , must return query ok==========")
-        for sql in self.__sqls_list:
-            tdSql.query(sql)
-            tdLog.success(f"{sql} executed success !")
+        for i in range(len(self.__sqls_list)):
+            tdSql.query(self.__sqls_list[i])
+            if i % 10 == 0 :
+                tdLog.success(f"{i} sql is already executed success !")
 
     def __join_check_old(self, tblist, checkrows, join_flag=True):
         query_conditions = self.__query_condition(tblist[0])
diff --git a/tests/system-test/2-query/union.py b/tests/system-test/2-query/union.py
index 853d707b63..729a4aab01 100644
--- a/tests/system-test/2-query/union.py
+++ b/tests/system-test/2-query/union.py
@@ -196,9 +196,9 @@ class TDTestCase:
         for i in range(len(sqls)):
             tdSql.query(sqls[i])
             res1_type = self.__get_type(0)
+            if i % 3 == 0:
+                    tdLog.success(f"{i} : sql is already executing!")
             for j in range(len(sqls[i:])):
-                if j % 100 == 0:
-                    tdLog.success(f"{i} : {j} sql is already executed!")
                 tdSql.query(sqls[j+i])
                 order_union_type = False
                 rev_order_type = False