You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/07/29 06:52:15 UTC
[incubator-iotdb] branch dyna_para_perf_test created (now 7770e77)
This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch dyna_para_perf_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
at 7770e77 add log for test
This branch includes the following new commits:
new 7770e77 add log for test
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.
[incubator-iotdb] 01/01: add log for test
Posted by lt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lta pushed a commit to branch dyna_para_perf_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 7770e77d963304d5aa868643357eda3b63089624
Author: lta <li...@163.com>
AuthorDate: Mon Jul 29 14:51:51 2019 +0800
add log for test
---
.../db/conf/adapter/IoTDBConfigDynamicAdapter.java | 33 ++++++++++++++++++++--
1 file changed, 30 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/adapter/IoTDBConfigDynamicAdapter.java b/server/src/main/java/org/apache/iotdb/db/conf/adapter/IoTDBConfigDynamicAdapter.java
index cb4bae1..e91f22d 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/adapter/IoTDBConfigDynamicAdapter.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/adapter/IoTDBConfigDynamicAdapter.java
@@ -212,10 +212,16 @@ public class IoTDBConfigDynamicAdapter implements IDynamicAdapter {
* TODO: Currently IoTDB only supports to add a storage group.
*/
@Override
- public void addOrDeleteStorageGroup(int diff) throws ConfigAdjusterException {
+ public synchronized void addOrDeleteStorageGroup(int diff) throws ConfigAdjusterException {
+ LOGGER.info(
+ "Before adding a storage group, storage group size is {}, timeseries size is {}, max memTable num is {}, tsFile threshold is {}, memtableSize is {}, memTableSizeFloorThreshold is {}",
+ totalStorageGroup, totalTimeseries, maxMemTableNum, CONFIG.getTsFileSizeThreshold(),
+ CONFIG.getMemtableSizeThreshold(),
+ getMemTableSizeFloorThreshold());
+
totalStorageGroup += diff;
maxMemTableNum += 4 * diff;
- if(!CONFIG.isEnableParameterAdapter()){
+ if (!CONFIG.isEnableParameterAdapter()) {
CONFIG.setMaxMemtableNumber(maxMemTableNum);
return;
}
@@ -225,13 +231,26 @@ public class IoTDBConfigDynamicAdapter implements IDynamicAdapter {
throw new ConfigAdjusterException(
"The IoTDB system load is too large to create storage group.");
}
+ LOGGER.info(
+ "After adding a storage group, storage group size is {}, timeseries size is {}, max memTable num is {}, tsFile threshold is {}, memtableSize is {}, memTableSizeFloorThreshold is {}",
+ totalStorageGroup, totalTimeseries, maxMemTableNum, CONFIG.getTsFileSizeThreshold(),
+ CONFIG.getMemtableSizeThreshold(),
+ getMemTableSizeFloorThreshold());
}
@Override
- public void addOrDeleteTimeSeries(int diff) throws ConfigAdjusterException {
+ public synchronized void addOrDeleteTimeSeries(int diff) throws ConfigAdjusterException {
if(!CONFIG.isEnableParameterAdapter()){
return;
}
+ if((totalTimeseries + 1) % 100 == 0) {
+ LOGGER.info(
+ "Before adding a timeseries, storage group size is {}, timeseries size is {}, max memTable num is {}, tsFile threshold is {}, memtableSize is {}, memTableSizeFloorThreshold is {}",
+ totalStorageGroup, totalTimeseries, maxMemTableNum, CONFIG.getTsFileSizeThreshold(),
+ CONFIG.getMemtableSizeThreshold(),
+ getMemTableSizeFloorThreshold());
+ }
+
totalTimeseries += diff;
staticMemory += diff * TIMESERIES_METADATA_SIZE_IN_BYTE;
if (!tryToAdaptParameters()) {
@@ -239,6 +258,14 @@ public class IoTDBConfigDynamicAdapter implements IDynamicAdapter {
staticMemory -= diff * TIMESERIES_METADATA_SIZE_IN_BYTE;
throw new ConfigAdjusterException("The IoTDB system load is too large to add timeseries.");
}
+
+ if(totalTimeseries % 100 == 0) {
+ LOGGER.info(
+ "After adding a timeseries, storage group size is {}, timeseries size is {}, max memTable num is {}, tsFile threshold is {}, memtableSize is {}, memTableSizeFloorThreshold is {}",
+ totalStorageGroup, totalTimeseries, maxMemTableNum, CONFIG.getTsFileSizeThreshold(),
+ CONFIG.getMemtableSizeThreshold(),
+ getMemTableSizeFloorThreshold());
+ }
}
public void setInitialized(boolean initialized) {