xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:[TD-30883]send hb before close in tmq

This commit is contained in:
wangmm0220 2024-07-08 13:51:30 +08:00
parent 322c0633aa
commit 7ff7ef1d73
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/system-test/7-tmq/tmqParamsTest.py
View File

@ -123,7 +123,6 @@ class TDTestCase:
tmqCom.insert_data(tdSql,paraDict["dbName"],paraDict["ctbPrefix"],paraDict["ctbNum"],paraDict["rowsPerTbl"],paraDict["batchNum"],int(round(time.time()*1000))) tmqCom.insert_data(tdSql,paraDict["dbName"],paraDict["ctbPrefix"],paraDict["ctbNum"],paraDict["rowsPerTbl"],paraDict["batchNum"],int(round(time.time()*1000)))
stop_flag = 1 stop_flag = 1
finally: finally:
time.sleep(5) #wait for send heartbeat to update subscription info.
consumer.unsubscribe() consumer.unsubscribe()
consumer.close() consumer.close()
tdSql.checkEqual(consumer_info, expected_parameters) tdSql.checkEqual(consumer_info, expected_parameters)