fix ci
This commit is contained in:
parent
7de0a34ae6
commit
43699959c8
|
@ -766,12 +766,11 @@ static int32_t collectMetaKeyFromDropViewStmt(SCollectMetaKeyCxt* pCxt, SDropVie
|
||||||
|
|
||||||
static int32_t collectMetaKeyFromCreateTSMAStmt(SCollectMetaKeyCxt* pCxt, SCreateTSMAStmt* pStmt) {
|
static int32_t collectMetaKeyFromCreateTSMAStmt(SCollectMetaKeyCxt* pCxt, SCreateTSMAStmt* pStmt) {
|
||||||
int32_t code;
|
int32_t code;
|
||||||
if (pStmt->pOptions->recursiveTsma) {
|
if (pStmt->pOptions->recursiveTsma && strlen(pStmt->tableName) + strlen(TSMA_RES_STB_POSTFIX) <= TSDB_TABLE_NAME_LEN) {
|
||||||
// if creating recursive tsma, the tablename is tsmaName
|
// if creating recursive tsma, the tablename is tsmaName
|
||||||
code = reserveTSMAInfoInCache(pCxt->pParseCxt->acctId, pStmt->dbName, pStmt->tableName, pCxt->pMetaCache);
|
code = reserveTSMAInfoInCache(pCxt->pParseCxt->acctId, pStmt->dbName, pStmt->tableName, pCxt->pMetaCache);
|
||||||
if (TSDB_CODE_SUCCESS == code) {
|
if (TSDB_CODE_SUCCESS == code) {
|
||||||
char dstTbName[TSDB_TABLE_NAME_LEN] = {0};
|
char dstTbName[TSDB_TABLE_NAME_LEN] = {0};
|
||||||
// TODO tsma check len
|
|
||||||
sprintf(dstTbName, "%s"TSMA_RES_STB_POSTFIX, pStmt->tableName);
|
sprintf(dstTbName, "%s"TSMA_RES_STB_POSTFIX, pStmt->tableName);
|
||||||
code = reserveTableMetaInCache(pCxt->pParseCxt->acctId, pStmt->dbName, dstTbName, pCxt->pMetaCache);
|
code = reserveTableMetaInCache(pCxt->pParseCxt->acctId, pStmt->dbName, dstTbName, pCxt->pMetaCache);
|
||||||
if (TSDB_CODE_SUCCESS == code) {
|
if (TSDB_CODE_SUCCESS == code) {
|
||||||
|
|
|
@ -167,7 +167,6 @@ class TDTestCase:
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
self.check_setup_cluster_status()
|
self.check_setup_cluster_status()
|
||||||
sleep(9999999)
|
|
||||||
self.create_db_check_vgroups()
|
self.create_db_check_vgroups()
|
||||||
self.create_db_replica_3_insertdatas(self.db_name , self.replica , self.vgroups , self.tb_nums , self.row_nums)
|
self.create_db_replica_3_insertdatas(self.db_name , self.replica , self.vgroups , self.tb_nums , self.row_nums)
|
||||||
self.check_insert_status(self.db_name , self.tb_nums , self.row_nums)
|
self.check_insert_status(self.db_name , self.tb_nums , self.row_nums)
|
||||||
|
|
Loading…
Reference in New Issue