diff --git a/src/plugins/monitor/src/monMain.c b/src/plugins/monitor/src/monMain.c index 932724a2c58d947dca01f56643bdf539537cb2a5..8830c47e14875bf7e214bbc006df8e38e602a093 100644 --- a/src/plugins/monitor/src/monMain.c +++ b/src/plugins/monitor/src/monMain.c @@ -200,7 +200,6 @@ static void *monThreadFunc(void *param) { if (tsMonitor.state == MON_STATE_INITED) { if (accessTimes % tsMonitorInterval == 0 || accessTimes == 1) { - monSaveSystemInfo(); monSaveDnodesInfo(); if (monHasMnodeMaster) { //only mnode master will write cluster info @@ -210,6 +209,7 @@ static void *monThreadFunc(void *param) { monSaveSlowQueryInfo(); monSaveDisksInfo(); monSaveGrantsInfo(); + monSaveSystemInfo(); } } } diff --git a/src/vnode/src/vnodeWrite.c b/src/vnode/src/vnodeWrite.c index ef0281277a5f23995fac70168348c6c18fad5655..c76298ae11bf6ef9bca2145f9bd805060b131a92 100644 --- a/src/vnode/src/vnodeWrite.c +++ b/src/vnode/src/vnodeWrite.c @@ -170,10 +170,13 @@ static int32_t vnodeProcessSubmitMsg(SVnodeObj *pVnode, void *pCont, SRspRet *pR if (tsdbInsertData(pVnode->tsdb, pCont, pRsp) < 0) { code = terrno; } else { - atomic_fetch_add_32(&tsSubmitReqSucNum, 1); + if (pRsp != NULL) atomic_fetch_add_32(&tsSubmitReqSucNum, 1); + } + + if (pRsp) { + atomic_fetch_add_32(&tsSubmitRowNum, ntohl(pRsp->numOfRows)); + atomic_fetch_add_32(&tsSubmitRowSucNum, ntohl(pRsp->affectedRows)); } - atomic_fetch_add_32(&tsSubmitRowNum, ntohl(pRsp->numOfRows)); - atomic_fetch_add_32(&tsSubmitRowSucNum, ntohl(pRsp->affectedRows)); return code; }