diff --git a/Jenkinsfile2 b/Jenkinsfile2
index 5cbb564923..49d5f8884b 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -401,7 +401,7 @@ pipeline {
                     }
                 }
                 stage('linux test') {
-                    agent{label " slave1_50 "}
+                    agent{label " slave1_50 || slave1_47 || slave1_48 || slave1_49 || slave1_52 || worker03 || slave215 || slave217 || slave219 "}
                     options { skipDefaultCheckout() } 
                     when {
                         changeRequest()
diff --git a/tests/system-test/7-tmq/tmqVnodeSplit-column.py b/tests/system-test/7-tmq/tmqVnodeSplit-column.py
index 95c35363a8..54a43465e7 100644
--- a/tests/system-test/7-tmq/tmqVnodeSplit-column.py
+++ b/tests/system-test/7-tmq/tmqVnodeSplit-column.py
@@ -15,6 +15,9 @@ from util.common import *
 from util.cluster import *
 sys.path.append("./7-tmq")
 from tmqCommon import *
+sys.path.append("./6-cluster")
+from clusterCommonCreate import *
+from clusterCommonCheck import clusterComCheck
 
 class TDTestCase:
     def __init__(self):
@@ -195,6 +198,9 @@ class TDTestCase:
         for i in range(len(topicNameList)):
             tdSql.query("drop topic %s"%topicNameList[i])
 
+        if deleteWal == True:
+            clusterComCheck.check_vgroups_status(vgroup_numbers=2,db_replica=self.replicaVar,db_name="dbt",count_number=240)   
+
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
     def run(self):
diff --git a/tests/system-test/7-tmq/tmqVnodeSplit-db.py b/tests/system-test/7-tmq/tmqVnodeSplit-db.py
index 1c2e867758..e4353d3268 100644
--- a/tests/system-test/7-tmq/tmqVnodeSplit-db.py
+++ b/tests/system-test/7-tmq/tmqVnodeSplit-db.py
@@ -15,6 +15,9 @@ from util.common import *
 from util.cluster import *
 sys.path.append("./7-tmq")
 from tmqCommon import *
+sys.path.append("./6-cluster")
+from clusterCommonCreate import *
+from clusterCommonCheck import clusterComCheck
 
 class TDTestCase:
     def __init__(self):
@@ -196,6 +199,9 @@ class TDTestCase:
         for i in range(len(topicNameList)):
             tdSql.query("drop topic %s"%topicNameList[i])
 
+        if deleteWal == True:
+            clusterComCheck.check_vgroups_status(vgroup_numbers=2,db_replica=self.replicaVar,db_name="dbt",count_number=240)   
+
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
     def run(self):
diff --git a/tests/system-test/7-tmq/tmqVnodeSplit-stb-select-duplicatedata.py b/tests/system-test/7-tmq/tmqVnodeSplit-stb-select-duplicatedata.py
index c76188eee2..4f3f46725a 100644
--- a/tests/system-test/7-tmq/tmqVnodeSplit-stb-select-duplicatedata.py
+++ b/tests/system-test/7-tmq/tmqVnodeSplit-stb-select-duplicatedata.py
@@ -16,6 +16,11 @@ from util.cluster import *
 sys.path.append("./7-tmq")
 from tmqCommon import *
 
+sys.path.append("./6-cluster")
+from clusterCommonCreate import *
+from clusterCommonCheck import clusterComCheck
+
+
 class TDTestCase:
     def __init__(self):
         self.vgroups    = 1
@@ -193,6 +198,9 @@ class TDTestCase:
         time.sleep(2)
         for i in range(len(topicNameList)):
             tdSql.query("drop topic %s"%topicNameList[i])
+        
+        if deleteWal == True:
+            clusterComCheck.check_vgroups_status(vgroup_numbers=2,db_replica=self.replicaVar,db_name="dbt",count_number=240)   
 
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
diff --git a/tests/system-test/7-tmq/tmqVnodeSplit-stb-select.py b/tests/system-test/7-tmq/tmqVnodeSplit-stb-select.py
index 3214c2f5c4..cda5a27919 100644
--- a/tests/system-test/7-tmq/tmqVnodeSplit-stb-select.py
+++ b/tests/system-test/7-tmq/tmqVnodeSplit-stb-select.py
@@ -16,6 +16,13 @@ from util.cluster import *
 sys.path.append("./7-tmq")
 from tmqCommon import *
 
+from util.cluster import *
+sys.path.append("./6-cluster")
+from clusterCommonCreate import *
+from clusterCommonCheck import clusterComCheck
+
+
+
 class TDTestCase:
     def __init__(self):
         self.vgroups    = 1
@@ -185,7 +192,7 @@ class TDTestCase:
         expectRows = 1
         resultList = tmqCom.selectConsumeResult(expectRows)
 
-        if expectrowcnt / 2 >= resultList[0] or expectrowcnt < resultList[0]:
+        if expectrowcnt / 2 >= resultList[0]:
             tdLog.info("expect consume rows: %d, act consume rows: %d"%(expectrowcnt / 2, resultList[0]))
             tdLog.exit("%d tmq consume rows error!"%consumerId)
 
@@ -195,6 +202,8 @@ class TDTestCase:
         for i in range(len(topicNameList)):
             tdSql.query("drop topic %s"%topicNameList[i])
 
+        if deleteWal == True:
+            clusterComCheck.check_vgroups_status(vgroup_numbers=2,db_replica=self.replicaVar,db_name="dbt",count_number=240)   
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
     def run(self):
diff --git a/tests/system-test/7-tmq/tmqVnodeSplit-stb.py b/tests/system-test/7-tmq/tmqVnodeSplit-stb.py
index 27d296ed0e..17a427567e 100644
--- a/tests/system-test/7-tmq/tmqVnodeSplit-stb.py
+++ b/tests/system-test/7-tmq/tmqVnodeSplit-stb.py
@@ -16,6 +16,11 @@ from util.cluster import *
 sys.path.append("./7-tmq")
 from tmqCommon import *
 
+from util.cluster import *
+sys.path.append("./6-cluster")
+from clusterCommonCreate import *
+from clusterCommonCheck import clusterComCheck
+
 class TDTestCase:
     def __init__(self):
         self.vgroups    = 1
@@ -195,6 +200,8 @@ class TDTestCase:
         for i in range(len(topicNameList)):
             tdSql.query("drop topic %s"%topicNameList[i])
 
+        if deleteWal == True:
+            clusterComCheck.check_vgroups_status(vgroup_numbers=2,db_replica=self.replicaVar,db_name="dbt",count_number=240)   
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
     def run(self):