test: add flush database

This commit is contained in:
Alex Duan 2023-05-17 16:36:59 +08:00
parent 0f22718c89
commit 0dbc60493f
1 changed files with 5 additions and 0 deletions

View File

@ -58,6 +58,10 @@ class RestoreBasic:
gen.create_child(self.stable, "d", self.child_count)
gen.set_batch_size(1000)
gen.insert_data(self.insert_rows)
tdSql.execute(f"flush database {self.dbname}")
# put some duplicate ts on wal
gen.insert_data(self.insert_rows%100)
for i in range(self.dnodes_num):
sql = f"create qnode on dnode {i+1}"
@ -135,6 +139,7 @@ class RestoreBasic:
# exec restore
sql = f"restore dnode {index}"
tdLog.info(sql)
tdSql.execute(sql)
self.check_corrent()