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

test: update test cases.

This commit is contained in:
Haojun Liao 2024-12-02 20:02:55 +08:00
parent 67d6458254
commit 8e319d777b
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/pytest/util/dnodes.py
View File

@ -39,7 +39,7 @@ class TDSimClient:
"rpcDebugFlag": "135", "rpcDebugFlag": "135",
"tmrDebugFlag": "131", "tmrDebugFlag": "131",
"dDebugFlag":"131", "dDebugFlag":"131",
"cDebugFlag": "131", "cDebugFlag": "135",
"uDebugFlag": "131", "uDebugFlag": "131",
"jniDebugFlag": "131", "jniDebugFlag": "131",
"qDebugFlag": "135", "qDebugFlag": "135",
@ -136,7 +136,7 @@ class TDDnode:
"dDebugFlag": "131", "dDebugFlag": "131",
"vDebugFlag": "131", "vDebugFlag": "131",
"tqDebugFlag": "135", "tqDebugFlag": "135",
"cDebugFlag": "131", "cDebugFlag": "135",
"stDebugFlag": "135", "stDebugFlag": "135",
"smaDebugFlag": "131", "smaDebugFlag": "131",
"jniDebugFlag": "131", "jniDebugFlag": "131",

3
tests/system-test/8-stream/checkpoint_info.py
View File

@ -21,6 +21,7 @@ from util.cluster import *
import threading import threading
# should be used by -N option # should be used by -N option
class TDTestCase: class TDTestCase:
updatecfgDict = {'debugFlag': 135, 'asynclog': 0, 'checkpointinterval':60}
#updatecfgDict = {'checkpointInterval': 60 ,} #updatecfgDict = {'checkpointInterval': 60 ,}
def init(self, conn, logSql, replicaVar=1): def init(self, conn, logSql, replicaVar=1):
@ -70,7 +71,7 @@ class TDTestCase:
while(True): while(True):
if(self.check_vnodestate()): if(self.check_vnodestate()):
break break
sql = 'select task_id, node_id, checkpoint_id, checkpoint_ver from information_schema.ins_stream_tasks where `level` = "source" or `level` = "agg" and node_type == "vnode"' sql = 'select task_id, node_id, checkpoint_id, checkpoint_ver from information_schema.ins_stream_tasks where `level` = "source" or `level` = "agg" and node_type = "vnode"'
for task_id, vnode, checkpoint_id, checkpoint_ver in tdSql.getResult(sql): for task_id, vnode, checkpoint_id, checkpoint_ver in tdSql.getResult(sql):
dirpath = f"{cluster.dnodes[self.vnode_dict[vnode]-1].dataDir}/vnode/vnode{vnode}/" dirpath = f"{cluster.dnodes[self.vnode_dict[vnode]-1].dataDir}/vnode/vnode{vnode}/"
info_path = self.find_checkpoint_info_file(dirpath, checkpoint_id, task_id) info_path = self.find_checkpoint_info_file(dirpath, checkpoint_id, task_id)