test: execute balancing vgroup in a loop
This commit is contained in:
parent
a94bdb643f
commit
b0c1e79f3a
|
@ -35,10 +35,11 @@ class TDTestCase:
|
||||||
|
|
||||||
def balance_vnode(self):
|
def balance_vnode(self):
|
||||||
leader_before = self.get_leader()
|
leader_before = self.get_leader()
|
||||||
tdSql.query("balance vgroup leader")
|
|
||||||
while True:
|
while True:
|
||||||
leader_after = -1
|
leader_after = -1
|
||||||
tdLog.debug("balancing vgroup leader")
|
tdLog.debug("balancing vgroup leader")
|
||||||
|
tdSql.query("balance vgroup leader")
|
||||||
while True:
|
while True:
|
||||||
tdLog.debug("get new vgroup leader")
|
tdLog.debug("get new vgroup leader")
|
||||||
leader_after = self.get_leader()
|
leader_after = self.get_leader()
|
||||||
|
@ -51,6 +52,7 @@ class TDTestCase:
|
||||||
break
|
break
|
||||||
else :
|
else :
|
||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
|
tdLog.debug("leader not changed")
|
||||||
|
|
||||||
|
|
||||||
def consume_TS_4674_Test(self):
|
def consume_TS_4674_Test(self):
|
||||||
|
|
Loading…
Reference in New Issue