This is an automated email from the ASF dual-hosted git repository.
liurui pushed a commit to branch file_size_monitor
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/file_size_monitor by this push:
new a5acc0c fix config usage in UT
a5acc0c is described below
commit a5acc0c731ee0f842e5adb5bfe808d8335d495e2
Author: liuruiyiyang <[email protected]>
AuthorDate: Fri Mar 8 10:39:51 2019 +0800
fix config usage in UT
---
.../main/java/org/apache/iotdb/db/monitor/collector/FileSize.java | 4 ++--
iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java | 6 +++---
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
b/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
index f3f1c13..ccf16f2 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
@@ -97,7 +97,7 @@ public class FileSize implements IStatistic {
}
private FileSize() {
- if (config.enableStatMonitor) {
+ if (config.isEnableStatMonitor()) {
StatMonitor statMonitor = StatMonitor.getInstance();
registerStatMetadata();
statMonitor.registerStatistics(MonitorConstants.FILE_SIZE_STORAGE_GROUP_NAME,
this);
@@ -120,7 +120,7 @@ public class FileSize implements IStatistic {
if (kinds.equals(MonitorConstants.FileSizeConstants.SETTLED)) {
//sum bufferWriteDirs size
long settledSize = INIT_VALUE_IF_FILE_NOT_EXIST;
- for (String bufferWriteDir : config.bufferWriteDirs) {
+ for (String bufferWriteDir : config.getBufferWriteDirs()) {
File settledFile = new File(bufferWriteDir);
if (settledFile.exists()) {
try {
diff --git a/iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java
b/iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java
index 0999ac4..1f959e1 100644
--- a/iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java
+++ b/iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java
@@ -51,13 +51,13 @@ public class MonitorTest {
// modify stat parameter
EnvironmentUtils.closeMemControl();
EnvironmentUtils.envSetUp();
- ioTDBConfig.enableStatMonitor = true;
- ioTDBConfig.backLoopPeriodSec = 1;
+ ioTDBConfig.setEnableStatMonitor(true);
+ ioTDBConfig.setBackLoopPeriodSec(1);
}
@After
public void tearDown() throws Exception {
- ioTDBConfig.enableStatMonitor = false;
+ ioTDBConfig.setEnableStatMonitor(false);
statMonitor.close();
EnvironmentUtils.cleanEnv();
}