diff --git a/src/system/detail/src/vnodeImport.c b/src/system/detail/src/vnodeImport.c index 5924caf6f431c690e09905b306cfaa539745d39d..4d1d671096b5b1f8537b0af8483153f25d6acc8c 100644 --- a/src/system/detail/src/vnodeImport.c +++ b/src/system/detail/src/vnodeImport.c @@ -243,7 +243,7 @@ int vnodeImportPoints(SMeterObj *pObj, char *cont, int contLen, char source, voi pthread_mutex_unlock(&pPool->vmutex); vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING); return TSDB_CODE_ACTION_IN_PROGRESS; - + } else { pPool->commitInProcess = 1; pthread_mutex_unlock(&pPool->vmutex); @@ -251,9 +251,9 @@ int vnodeImportPoints(SMeterObj *pObj, char *cont, int contLen, char source, voi *pNumOfPoints = import.importedRows; } pVnode->version++; + vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING); } - vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING); return code; }