You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2021/03/16 03:36:54 UTC
[iotdb] branch fix-monitor-path-bug created (now 186e55f)
This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch fix-monitor-path-bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 186e55f fix monitor bug
This branch includes the following new commits:
new 186e55f fix monitor bug
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: fix monitor bug
Posted by xu...@apache.org.
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 <15...@smail.nju.edu.cn>
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);
}