This is an automated email from the ASF dual-hosted git repository. xuekaifeng pushed a commit to branch fix-monitor-path-bug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 186e55f33142d26860696949ba6b88d96d41325d Author: 151250176 <[email protected]> AuthorDate: Tue Mar 16 11:35:48 2021 +0800 fix monitor bug --- .../main/java/org/apache/iotdb/db/engine/flush/FlushManager.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java index a741f93..d0324c1 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java @@ -18,6 +18,9 @@ */ package org.apache.iotdb.db.engine.flush; +import static java.io.File.separator; + +import java.util.concurrent.ConcurrentLinkedDeque; import org.apache.iotdb.db.concurrent.WrappedRunnable; import org.apache.iotdb.db.conf.IoTDBConfig; import org.apache.iotdb.db.conf.IoTDBDescriptor; @@ -31,12 +34,9 @@ import org.apache.iotdb.db.monitor.StatMonitor; import org.apache.iotdb.db.service.IService; import org.apache.iotdb.db.service.JMXService; import org.apache.iotdb.db.service.ServiceType; - import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.concurrent.ConcurrentLinkedDeque; - public class FlushManager implements FlushManagerMBean, IService { private static final Logger LOGGER = LoggerFactory.getLogger(FlushManager.class); @@ -110,7 +110,8 @@ public class FlushManager implements FlushManagerMBean, IService { // update stat monitor cache to system during each flush() if (config.isEnableStatMonitor() && config.isEnableMonitorSeriesWrite()) { try { - StatMonitor.getInstance().saveStatValue(tsFileProcessor.getStorageGroupName()); + StatMonitor.getInstance() + .saveStatValue(tsFileProcessor.getStorageGroupName().split(separator)[0]); } catch (StorageEngineException | MetadataException e) { LOGGER.error("Inserting monitor series data error.", e); }
