Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TS-4243-3.0
This commit is contained in:
commit
2c1f978fd2
|
@ -1008,11 +1008,11 @@ void metaDropTables(SMeta *pMeta, SArray *tbUids) {
|
|||
}
|
||||
tSimpleHashPut(suidHash, &suid, sizeof(tb_uid_t), &nCtbDropped, sizeof(int64_t));
|
||||
}
|
||||
|
||||
/*
|
||||
if (!TSDB_CACHE_NO(pMeta->pVnode->config)) {
|
||||
tsdbCacheDropTable(pMeta->pVnode->pTsdb, uid, suid, NULL);
|
||||
}
|
||||
|
||||
*/
|
||||
metaDebug("batch drop table:%" PRId64, uid);
|
||||
}
|
||||
metaULock(pMeta);
|
||||
|
|
|
@ -461,7 +461,7 @@ SOperatorInfo* createIndefinitOutputOperatorInfo(SOperatorInfo* downstream, SPhy
|
|||
_error:
|
||||
destroyIndefinitOperatorInfo(pInfo);
|
||||
taosMemoryFree(pOperator);
|
||||
pTaskInfo->code = TSDB_CODE_OUT_OF_MEMORY;
|
||||
pTaskInfo->code = code;
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
|
|
@ -60,13 +60,13 @@ extern char* tsMonFwUri;
|
|||
#define CPU_SYSTEM DNODE_TABLE":cpu_system"
|
||||
#define CPU_CORE DNODE_TABLE":cpu_cores"
|
||||
#define MEM_ENGINE DNODE_TABLE":mem_engine"
|
||||
#define MEM_SYSTEM DNODE_TABLE":mem_system"
|
||||
#define MEM_SYSTEM DNODE_TABLE":mem_free"
|
||||
#define MEM_TOTAL DNODE_TABLE":mem_total"
|
||||
#define DISK_ENGINE DNODE_TABLE":disk_engine"
|
||||
#define DISK_USED DNODE_TABLE":disk_used"
|
||||
#define DISK_TOTAL DNODE_TABLE":disk_total"
|
||||
#define NET_IN DNODE_TABLE":net_in"
|
||||
#define NET_OUT DNODE_TABLE":net_out"
|
||||
#define NET_IN DNODE_TABLE":system_net_in"
|
||||
#define NET_OUT DNODE_TABLE":system_net_out"
|
||||
#define IO_READ DNODE_TABLE":io_read"
|
||||
#define IO_WRITE DNODE_TABLE":io_write"
|
||||
#define IO_READ_DISK DNODE_TABLE":io_read_disk"
|
||||
|
|
|
@ -57,7 +57,7 @@ typedef enum {
|
|||
#define SCHEDULE_DEFAULT_POLICY SCH_LOAD_SEQ
|
||||
#define SCHEDULE_DEFAULT_MAX_NODE_NUM 20
|
||||
|
||||
#define SCH_DEFAULT_TASK_TIMEOUT_USEC 5000000
|
||||
#define SCH_DEFAULT_TASK_TIMEOUT_USEC 30000000
|
||||
#define SCH_MAX_TASK_TIMEOUT_USEC 300000000
|
||||
#define SCH_DEFAULT_MAX_RETRY_NUM 6
|
||||
#define SCH_MIN_AYSNC_EXEC_NUM 3
|
||||
|
|
|
@ -33,7 +33,7 @@ int32_t schedulerInit() {
|
|||
schMgmt.cfg.maxJobNum = SCHEDULE_DEFAULT_MAX_JOB_NUM;
|
||||
schMgmt.cfg.maxNodeTableNum = tsQueryMaxConcurrentTables;
|
||||
schMgmt.cfg.schPolicy = SCHEDULE_DEFAULT_POLICY;
|
||||
schMgmt.cfg.enableReSchedule = true;
|
||||
schMgmt.cfg.enableReSchedule = false;
|
||||
|
||||
qDebug("schedule init, policy: %d, maxNodeTableNum: %" PRId64", reSchedule:%d",
|
||||
schMgmt.cfg.schPolicy, schMgmt.cfg.maxNodeTableNum, schMgmt.cfg.enableReSchedule);
|
||||
|
|
Loading…
Reference in New Issue