You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2021/05/14 04:08:16 UTC
[iotdb] branch concurrent_writing_time_partition updated: [To
rel/0.12] enable concurrent_writing_time_partition
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch concurrent_writing_time_partition
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/concurrent_writing_time_partition by this push:
new 87c92db [To rel/0.12] enable concurrent_writing_time_partition
87c92db is described below
commit 87c92db0803d4e418112c800f63eb3f5544d228a
Author: HTHou <hh...@outlook.com>
AuthorDate: Fri May 14 12:07:32 2021 +0800
[To rel/0.12] enable concurrent_writing_time_partition
---
server/src/assembly/resources/conf/iotdb-engine.properties | 2 ++
.../src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +++++---
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties b/server/src/assembly/resources/conf/iotdb-engine.properties
index ddf1f10..54ae811 100644
--- a/server/src/assembly/resources/conf/iotdb-engine.properties
+++ b/server/src/assembly/resources/conf/iotdb-engine.properties
@@ -663,3 +663,5 @@ timestamp_precision=ms
# time range for partitioning data inside each storage group, the unit is second
# partition_interval=604800
+
+# concurrent_writing_time_partition=1
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index 43f17be..8a133da 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -600,9 +600,11 @@ public class IoTDBDescriptor {
// String.valueOf(conf.getPartitionInterval()))));
// the num of memtables in each storage group
- // conf.setConcurrentWritingTimePartition(
- // Integer.parseInt(properties.getProperty("concurrent_writing_time_partition",
- // String.valueOf(conf.getConcurrentWritingTimePartition()))));
+ conf.setConcurrentWritingTimePartition(
+ Integer.parseInt(
+ properties.getProperty(
+ "concurrent_writing_time_partition",
+ String.valueOf(conf.getConcurrentWritingTimePartition()))));
conf.setTimeIndexLevel(
properties.getProperty("time_index_level", String.valueOf(conf.getTimeIndexLevel())));