Skip to content

TDengine
TDengine

taosdata / TDengine
大约 2 年 前同步成功

通知 1192
Star 22018
Fork 4786
TDengine
TDengine
未验证 提交 6fadbbc8 编写于 作者: H Hui Li 提交者： GitHub
浏览文件
操作

Update tmqConsFromTsdb1-mutilVg-mutilCtb-funcNFilter.py

上级 5aacd9f2
隐藏空白更改
内联 并排
Showing with 4 addition and 4 deletion
tests/system-test/7-tmq/tmqConsFromTsdb1-mutilVg-mutilCtb-funcNFilter.py
浏览文件 @ 6fadbbc8
...@@ -199,11 +199,11 @@ class TDTestCase: ...@@ -199,11 +199,11 @@ class TDTestCase:
tdLog.info("start consume processor 0") tdLog.info("start consume processor 0")
tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot']) tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot'])
tdLog.info("wait start consume notify")
tmqCom.getStartConsumeNotifyFromTmqsim()
tdLog.info("wait commit notify") tdLog.info("wait commit notify")
tmqCom.getStartCommitNotifyFromTmqsim() tmqCom.getStartCommitNotifyFromTmqsim(rows=2)
# tdLog.info("wait start consume notify")
# tmqCom.getStartConsumeNotifyFromTmqsim()
tdLog.info("pkill consume processor") tdLog.info("pkill consume processor")
tdCom.killProcessor("tmq_sim") tdCom.killProcessor("tmq_sim")
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或