This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch add_config_cross_to_master in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7188916211d10d41c8cc25b091817a021ab94685 Author: Jinrui.Zhang <[email protected]> AuthorDate: Fri May 5 16:46:45 2023 +0800 add config min_cross_compaction_unseq_file_level for cross compaction --- node-commons/src/assembly/resources/conf/iotdb-common.properties | 4 ++++ server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 7 ++++++- 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/node-commons/src/assembly/resources/conf/iotdb-common.properties b/node-commons/src/assembly/resources/conf/iotdb-common.properties index 5df61be0a7e..ad523550f1d 100644 --- a/node-commons/src/assembly/resources/conf/iotdb-common.properties +++ b/node-commons/src/assembly/resources/conf/iotdb-common.properties @@ -621,6 +621,10 @@ cluster_name=defaultCluster # Datatype: long, Unit: byte # max_cross_compaction_candidate_file_size=5368709120 +# The min inner compaction level of unsequence file which can be selected as candidate +# Datatype: int +# min_cross_compaction_unseq_file_level=1 + # If one merge file selection runs for more than this time, it will be ended and its current # selection will be used as final selection. # When < 0, it means time is unbounded. 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 c8548835dbf..fb983d4273d 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 @@ -676,7 +676,12 @@ public class IoTDBDescriptor { properties.getProperty( "max_cross_compaction_candidate_file_size", Long.toString(conf.getMaxCrossCompactionCandidateFileSize())))); - + conf.setMinCrossCompactionUnseqFileLevel( + Integer.parseInt( + properties.getProperty( + "min_cross_compaction_unseq_file_level", + Integer.toString(conf.getMinCrossCompactionUnseqFileLevel())))); + conf.setCompactionWriteThroughputMbPerSec( Integer.parseInt( properties.getProperty(
