提交 2c516975 编写于 作者: P Ping Xiao

update crash_gen script

上级 f2b43862
...@@ -2053,10 +2053,16 @@ class TdSuperTable: ...@@ -2053,10 +2053,16 @@ class TdSuperTable:
consumer.commit(res) consumer.commit(res)
if time.time() - time_start > random.randint(5, 50): if time.time() - time_start > random.randint(5, 50):
break break
consumer.unsubscribe() try:
consumer.close() consumer.unsubscribe()
except TmqError as err: # topic deleted by other threads consumer.close()
pass except TmqError as e:
pass
except taos.error.ProgrammingError as err:
errno = Helper.convertErrno(err.errno)
if errno in [0x03E1]: # topic deleted by other threads
pass
return return
# mulit Consumer # mulit Consumer
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册