From ed253f2a2a57af0605891c0bc3c3beccc3867ed7 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Tue, 26 Nov 2019 17:47:29 +0800 Subject: [PATCH] fix a small bug --- src/system/detail/src/vnodeImport.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/system/detail/src/vnodeImport.c b/src/system/detail/src/vnodeImport.c index 5924caf6f4..4d1d671096 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; } -- GitLab