commit
7038a9926b
|
@ -415,7 +415,11 @@ static int32_t balanceMonitorVgroups() {
|
||||||
} else if (vgReplica < dbReplica) {
|
} else if (vgReplica < dbReplica) {
|
||||||
mInfo("vgId:%d, replica:%d numOfVnodes:%d, try add one vnode", pVgroup->vgId, dbReplica, vgReplica);
|
mInfo("vgId:%d, replica:%d numOfVnodes:%d, try add one vnode", pVgroup->vgId, dbReplica, vgReplica);
|
||||||
hasUpdatingVgroup = true;
|
hasUpdatingVgroup = true;
|
||||||
balanceAddVnode(pVgroup, NULL, NULL);
|
int32_t code = balanceAddVnode(pVgroup, NULL, NULL);
|
||||||
|
if (code == TSDB_CODE_SUCCESS) {
|
||||||
|
mnodeDecVgroupRef(pVgroup);
|
||||||
|
break;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
mnodeDecVgroupRef(pVgroup);
|
mnodeDecVgroupRef(pVgroup);
|
||||||
|
|
|
@ -303,7 +303,7 @@ void tsDataSwap(void *pLeft, void *pRight, int32_t type, int32_t size);
|
||||||
|
|
||||||
#define TSDB_MIN_DAYS_PER_FILE 1
|
#define TSDB_MIN_DAYS_PER_FILE 1
|
||||||
#define TSDB_MAX_DAYS_PER_FILE 3650
|
#define TSDB_MAX_DAYS_PER_FILE 3650
|
||||||
#define TSDB_DEFAULT_DAYS_PER_FILE 10
|
#define TSDB_DEFAULT_DAYS_PER_FILE 2
|
||||||
|
|
||||||
#define TSDB_MIN_KEEP 1 // data in db to be reserved.
|
#define TSDB_MIN_KEEP 1 // data in db to be reserved.
|
||||||
#define TSDB_MAX_KEEP 365000 // data in db to be reserved.
|
#define TSDB_MAX_KEEP 365000 // data in db to be reserved.
|
||||||
|
|
|
@ -30,7 +30,7 @@
|
||||||
#include "syncInt.h"
|
#include "syncInt.h"
|
||||||
|
|
||||||
// global configurable
|
// global configurable
|
||||||
int tsMaxSyncNum = 4;
|
int tsMaxSyncNum = 2;
|
||||||
int tsSyncTcpThreads = 2;
|
int tsSyncTcpThreads = 2;
|
||||||
int tsMaxWatchFiles = 100;
|
int tsMaxWatchFiles = 100;
|
||||||
int tsMaxFwdInfo = 200;
|
int tsMaxFwdInfo = 200;
|
||||||
|
|
Loading…
Reference in New Issue