[iotdb] branch concurrent_writing_time_partition updated: [To rel/0.12] enable concurrent_writing_time_partition

[haonan]

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 <hhao...@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())));