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

fix:[TS-5679] auto commit error

This commit is contained in:
wangmm0220 2024-11-24 21:21:26 +08:00
parent e3b5c61699
commit 4a9d2dbf44
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/system-test/7-tmq/tmq_offset.py
View File

@ -45,6 +45,11 @@ class TDTestCase:
tdLog.exit("tmq_offset_test error!") tdLog.exit("tmq_offset_test error!")
else: else:
buildPath = tdCom.getBuildPath() buildPath = tdCom.getBuildPath()
cmdStr0 = '%s/build/bin/tmq_offset_test 5679'%(buildPath)
tdLog.info(cmdStr0)
if os.system(cmdStr0) != 0:
tdLog.exit(cmdStr0)
cmdStr1 = '%s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y &'%(buildPath) cmdStr1 = '%s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y &'%(buildPath)
tdLog.info(cmdStr1) tdLog.info(cmdStr1)
os.system(cmdStr1) os.system(cmdStr1)

11
utils/test/c/tmq_offset_test.c
View File

@ -144,6 +144,7 @@ void test_ts5679(TAOS* pConn){
for(int i = 0; i < numOfAssign; i++){ for(int i = 0; i < numOfAssign; i++){
int64_t committed = tmq_committed(tmq, "t_5679", pAssign[i].vgId); int64_t committed = tmq_committed(tmq, "t_5679", pAssign[i].vgId);
printf("committed offset:%"PRId64"\n", committed);
ASSERT(committed == TSDB_CODE_TMQ_NO_COMMITTED); ASSERT(committed == TSDB_CODE_TMQ_NO_COMMITTED);
} }
@ -374,9 +375,13 @@ void test_ts3756(TAOS* pConn){
int main(int argc, char* argv[]) { int main(int argc, char* argv[]) {
TAOS* pConn = taos_connect("localhost", "root", "taosdata", NULL, 0); TAOS* pConn = taos_connect("localhost", "root", "taosdata", NULL, 0);
test_offset(pConn); if (argc == 2) {
test_ts3756(pConn); test_ts5679(pConn);
test_ts5679(pConn); }else{
test_offset(pConn);
test_ts3756(pConn);
}
taos_close(pConn); taos_close(pConn);
return 0; return 0;
} }