test: add log
This commit is contained in:
parent
944b0d26ef
commit
138a358549
|
@ -237,6 +237,7 @@ class TDTestCase:
|
||||||
|
|
||||||
# kill taosBenchmark
|
# kill taosBenchmark
|
||||||
tmqCom.killProcesser("taosBenchmark")
|
tmqCom.killProcesser("taosBenchmark")
|
||||||
|
tdLog.info("kill taosBenchmak end")
|
||||||
|
|
||||||
# wait the status to "lost"
|
# wait the status to "lost"
|
||||||
while (1):
|
while (1):
|
||||||
|
@ -252,10 +253,13 @@ class TDTestCase:
|
||||||
if (1 == exitFlag):
|
if (1 == exitFlag):
|
||||||
break
|
break
|
||||||
|
|
||||||
|
tdLog.info("all consumers status into 'lost'")
|
||||||
|
|
||||||
# drop consumer groups
|
# drop consumer groups
|
||||||
for i in range(len(groupIdList)):
|
for i in range(len(groupIdList)):
|
||||||
for j in range(len(topicNameList)):
|
for j in range(len(topicNameList)):
|
||||||
sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j])
|
sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j])
|
||||||
|
tdLog.info("drop consumer cmd: %s"%(sqlCmd))
|
||||||
tdSql.execute(sqlCmd)
|
tdSql.execute(sqlCmd)
|
||||||
|
|
||||||
tmqCom.g_end_insert_flag = 1
|
tmqCom.g_end_insert_flag = 1
|
||||||
|
|
Loading…
Reference in New Issue