This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 3115b09 [IOTDB-2326] add doc for compaction param (#4822)
3115b09 is described below
commit 3115b09609939f38582249a2f25898a61f54f197
Author: Liu Xuxin <[email protected]>
AuthorDate: Sun Jan 16 18:43:05 2022 +0800
[IOTDB-2326] add doc for compaction param (#4822)
---
docs/UserGuide/Appendix/Config-Manual.md | 150 ++++++++++++++-
docs/zh/UserGuide/Appendix/Config-Manual.md | 207 +++++++++++++--------
.../resources/conf/iotdb-engine.properties | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 10 +-
.../cross/inplace/manage/MergeManager.java | 3 +-
6 files changed, 287 insertions(+), 97 deletions(-)
diff --git a/docs/UserGuide/Appendix/Config-Manual.md
b/docs/UserGuide/Appendix/Config-Manual.md
index 187ae66..2cd8474 100644
--- a/docs/UserGuide/Appendix/Config-Manual.md
+++ b/docs/UserGuide/Appendix/Config-Manual.md
@@ -508,14 +508,152 @@ The permission definitions are in
${IOTDB\_CONF}/conf/jmx.access.
|Default| 10000 |
|Effective|After restarting system|
-* merge\_concurrent\_threads
+### Compaction Config
-|Name| merge\_concurrent\_threads |
+* concurrent\_compaction\_thread
+
+|Name| concurrent\_compaction\_thread |
|:---:|:---|
-|Description| THe max threads which can be used when unsequence data is
merged. The larger it is, the more IO and CPU cost. The smaller the value, the
more the disk is occupied when the unsequence data is too large, the reading
will be slower. |
-|Type|Int32|
-|Default| 0 |
-|Effective|After restarting system|
+|Description| thread num to execute compaction |
+|Type| Integer |
+|Default| 10 |
+|Effective|After restart system|
+
+* compaction\_schedule\_interval
+
+|Name| compaction\_schedule\_interval |
+|:---:|:---|
+|Description| interval of scheduling compaction |
+|Type| Long, the unit is millisecond |
+|Default| 60000, don't set it a small value |
+|Effective|After restart system|
+
+* compaction\_submission\_interval
+
+|Name| compaction\_submission\_interval |
+|:---:|:---|
+|Description| interval of submitting compaction task |
+|Type| Long, the unit is millisecond |
+|Default| 60000, don't set it a small value |
+|Effective|After restart system|
+
+* enable\_seq\_space\_compaction
+
+|Name| enable\_seq\_space\_compaction |
+|:---:|:---|
+|Description| enable the compaction between sequence files |
+|Type| Boolean |
+|Default| true |
+|Effective|After restart system|
+
+* enable\_unseq\_space\_compaction
+
+|Name| enable\_unseq\_space\_compaction |
+|:---:|:---|
+|Description| enable the compaction between unsequence files |
+|Type| Boolean |
+|Default| false |
+|Effective|After restart system|
+
+* enable\_cross\_space\_compaction
+
+|Name| enable\_cross\_space\_compaction |
+|:---:|:---|
+|Description| enable the compaction between sequence files and unsequence
files |
+|Type| Boolean |
+|Default| true |
+|Effective|After restart system|
+
+* cross\_compaction\_strategy
+
+|Name| cross\_compaction\_strategy |
+|:---:|:---|
+|Description| strategy of cross space compaction |
+|Type| String |
+|Default| inplace_compaction, current option is only inplace_compaction |
+|Effective|After restart system|
+
+* inner\_compaction\_strategy
+
+|Name| inner\_compaction\_strategy |
+|:---:|:---|
+|Description| strategy of inner space compaction |
+|Type| String |
+|Default| size_tiered_compaction, current option is only
size_tiered_compaction |
+|Effective|After restart system|
+
+* compaction\_priority
+
+|Name| compaction\_priority |
+|:---:|:---|
+|Description| Priority of compaction task. When it is balance, system executes
all types of compaction equally; when it is inner_cross, system takes
precedence over executing inner space compaction task; when it is cross_inner,
system takes precedence over executing cross space compaction task |
+|Type| String |
+|Default| inner_cross, options are inner_cross, balance, cross_inner |
+|Effective|After restart system|
+
+
+* target\_compaction\_file\_size
+
+|Name| target\_compaction\_file\_size |
+|:---:|:---|
+|Description| The target file is in inner space compaction |
+|Type| Long, the unit is byte |
+|Default| 1073741824 (1GB) |
+|Effective|After restart system|
+
+* max\_compaction\_candidate\_file\_num
+
+|Name| max\_compaction\_candidate\_file\_num |
+|:---:|:---|
+|Description| The max num of files encounter in compaction |
+|Type| Integer |
+|Default| 30, don't set it a small value |
+|Effective|After restart system|
+
+* target\_chunk\_size
+
+|Name| target\_chunk\_size |
+|:---:|:---|
+|Description| The target size of compacted chunk |
+|Type| Long, the unit is byte |
+|Default| 1048576 (1MB) |
+|Effective|After restart system|
+
+* target\_chunk\_point\_num
+
+|Name| target\_chunk\_point\_num |
+|:---:|:---|
+|Description| The target point number of compacted chunk |
+|Type| Integer |
+|Default| 100000 |
+|Effective|After restart system|
+
+* chunk\_size\_lower\_bound\_in\_compaction
+
+|Name| chunk\_size\_lower\_bound\_in\_compaction |
+|:---:|:---|
+|Description| A source chunk will be deserialized in compaction when its size
is less than this value |
+|Type| Long, the unit is byte |
+|Default| 128 |
+|Effective|After restart system|
+
+* chunk\_point\_num\_lower\_bound\_in\_compaction
+
+|Name| chunk\_size\_lower\_bound\_in\_compaction |
+|:---:|:---|
+|Description| A source chunk will be deserialized in compaction when its point
num is less than this value |
+|Type| Integer |
+|Default| 100 |
+|Effective|After restart system|
+
+* compaction\_write\_throughput\_mb\_per\_sec\
+
+|Name| compaction\_write\_throughput\_mb\_per\_sec\ |
+|:---:|:---|
+|Description| The write rate of all compaction tasks in MB/s |
+|Type| Integer |
+|Default| 8, don't set it a large value|
+|Effective|After restart system|
* enable\_stat\_monitor
diff --git a/docs/zh/UserGuide/Appendix/Config-Manual.md
b/docs/zh/UserGuide/Appendix/Config-Manual.md
index d81dcf3..5a5aa00 100644
--- a/docs/zh/UserGuide/Appendix/Config-Manual.md
+++ b/docs/zh/UserGuide/Appendix/Config-Manual.md
@@ -23,24 +23,29 @@
为方便 IoTDB Server 的配置与管理，IoTDB Server 为用户提供三种配置项，使得用户可以在启动服务或服务运行时对其进行配置。
-三种配置项的配置文件均位于 IoTDB 安装目录：`$IOTDB_HOME/conf`文件夹下，其中涉及 server 配置的共有 2
个文件，分别为：`iotdb-env.sh`, `iotdb-engine.properties`。用户可以通过更改其中的配置项对系统运行的相关配置项进行配置。
+三种配置项的配置文件均位于 IoTDB 安装目录：`$IOTDB_HOME/conf`文件夹下，其中涉及 server 配置的共有 2
个文件，分别为：`iotdb-env.sh`, `iotdb-engine.properties`
+。用户可以通过更改其中的配置项对系统运行的相关配置项进行配置。
配置文件的说明如下：
* `iotdb-env.sh`：环境配置项的默认配置文件。用户可以在文件中配置 JAVA-JVM 的相关系统配置项。
-* `iotdb-engine.properties`：IoTDB 引擎层系统配置项的默认配置文件。用户可以在文件中配置 IoTDB
引擎运行时的相关参数，如 JDBC 服务监听端口 (`rpc_port`)、overflow 数据文件存储目录 (`overflow_data_dir`)
等。此外，用户可以在文件中配置 IoTDB 存储时 TsFile 文件的相关信息，如每次将内存中的数据写入到磁盘时的数据大小
(`group_size_in_byte`)，内存中每个列打一次包的大小 (`page_size_in_byte`) 等。
+* `iotdb-engine.properties`：IoTDB 引擎层系统配置项的默认配置文件。用户可以在文件中配置 IoTDB
引擎运行时的相关参数，如 JDBC 服务监听端口 (`rpc_port`)、overflow
+ 数据文件存储目录 (`overflow_data_dir`) 等。此外，用户可以在文件中配置 IoTDB 存储时 TsFile
文件的相关信息，如每次将内存中的数据写入到磁盘时的数据大小 (`group_size_in_byte`)
+ ，内存中每个列打一次包的大小 (`page_size_in_byte`) 等。
## 热修改配置项
-为方便用户使用，IoTDB Server
为用户提供了热修改功能，即在系统运行过程中修改`iotdb-engine.properties`中部分配置参数并即时应用到系统中。下面介绍的参数中，改后
-生效方式为`触发生效`的均为支持热修改的配置参数。
+为方便用户使用，IoTDB Server
为用户提供了热修改功能，即在系统运行过程中修改`iotdb-engine.properties`中部分配置参数并即时应用到系统中。下面介绍的参数中，改后
生效方式为`触发生效`
+的均为支持热修改的配置参数。
-触发方式：客户端发送```load configuration```命令至 IoTDB Server，客户端的使用方式详见 [SQL
命令行终端（CLI）](https://iotdb.apache.org/zh/UserGuide/Master/CLI/Command-Line-Interface.html)
+触发方式：客户端发送```load configuration```命令至 IoTDB
+Server，客户端的使用方式详见 [SQL
命令行终端（CLI）](https://iotdb.apache.org/zh/UserGuide/Master/CLI/Command-Line-Interface.html)
## 环境配置项
-环境配置项主要用于对 IoTDB Server 运行的 Java 环境相关参数进行配置，如 JVM 相关配置。IoTDB Server
启动时，此部分配置会被传给 JVM。用户可以通过查看 `iotdb-env.sh`（或`iotdb-env.bat`)
文件查看环境配置项内容。详细配置项说明如下：
+环境配置项主要用于对 IoTDB Server 运行的 Java 环境相关参数进行配置，如 JVM 相关配置。IoTDB Server
启动时，此部分配置会被传给 JVM。用户可以通过查看 `iotdb-env.sh`
+（或`iotdb-env.bat`) 文件查看环境配置项内容。详细配置项说明如下：
* JMX\_LOCAL
@@ -80,7 +85,8 @@
## 系统配置项
-系统配置项是 IoTDB Server 运行的核心配置，它主要用于设置 IoTDB Server 文件层和引擎层的参数，便于用户根据自身需求调整
Server
的相关配置，以达到较好的性能表现。系统配置项可分为两大模块：文件层配置项和引擎层配置项。用户可以通过`iotdb-engine.properties`,
文件查看和修改两种配置项的内容。在 0.7.0 版本中字符串类型的配置项大小写敏感。
+系统配置项是 IoTDB Server 运行的核心配置，它主要用于设置 IoTDB Server 文件层和引擎层的参数，便于用户根据自身需求调整 Server
+的相关配置，以达到较好的性能表现。系统配置项可分为两大模块：文件层配置项和引擎层配置项。用户可以通过`iotdb-engine.properties`,
文件查看和修改两种配置项的内容。在 0.7.0 版本中字符串类型的配置项大小写敏感。
### RPC配置
@@ -166,7 +172,6 @@
| 类型 | INT32 |
| 默认值 | 8086 |
| 改后生效方式 | 重启服务生效 |
-
### 写前日志配置
* enable\_wal
@@ -526,19 +531,19 @@
* concurrent\_sub\_rawQuery\_thread
-|名字| concurrent\_sub\_rawQuery\_thread |
-|:---:|:--|
-|描述| 当 IoTDB 对内存中的数据进行原始数据查询时，最多启动多少个线程来执行该操作。如果该值小于等于 0，那么采用机器所安装的 CPU
核的数量。默认值为 8。|
-|类型| Int32 |
-|默认值| 8 |
+|名字| concurrent\_sub\_rawQuery\_thread |
+|:---:|:--|
+|描述| 原始数据查询时，最多启动多少个线程来执行该操作。如果设置小于等于 0，会采用机器 CPU 核数。|
+|类型| Int32 |
+|默认值| 8 |
|改后生效方式|重启服务生效|
* raw\_query\_blocking\_queue\_capacity
-|名字| raw\_query\_blocking\_queue\_capacity |
-|:---:|:--|
-|描述| 原始数据查询中，读任务的阻塞队列长度。默认值为 5。|
-|类型| Int32 |
+|名字| raw\_query\_blocking\_queue\_capacity |
+|:---:|:--|
+|描述| 原始数据查询中，读任务的阻塞队列长度。默认值为 5。|
+|类型| Int32 |
|默认值| 5 |
|改后生效方式|重启服务生效|
@@ -786,104 +791,149 @@
### 合并配置
-* compaction\_strategy
+* concurrent\_compaction\_thread
-|名字| compaction\_strategy |
+|名字| concurrent\_compaction\_thread |
|:---:|:---|
-|描述| 默认开启合并，可根据需求开启合并或关闭合并（LEVEL_COMPACTION, NO_COMPACTION） |
-|类型| String |
-|默认值| LEVEL_COMPACTION |
+|描述| 执行合并任务的线程数目 |
+|类型| Integer |
+|默认值| 10 |
+|改后生效方式|重启服务生效|
+
+* compaction\_schedule\_interval
+
+|名字| compaction\_schedule\_interval |
+|:---:|:---|
+|描述| 合并调度的时间间隔 |
+|类型| Long，单位为毫秒 |
+|默认值| 60000，建议不要设置的太小 |
+|改后生效方式|重启服务生效|
+
+* compaction\_submission\_interval
+
+|名字| compaction\_submission\_interval |
+|:---:|:---|
+|描述| 合并任务提交的间隔 |
+|类型| Long，单位为毫秒 |
+|默认值| 60000，建议不要设置的太小 |
|改后生效方式|重启服务生效|
-* enable\_unseq_compaction
+* enable\_seq\_space\_compaction
-|名字| enable\_unseq_compaction |
+|名字| enable\_seq\_space\_compaction |
|:---:|:---|
-|描述| 是否将unseq文件合并为seq文件。仅当compaction_strategy为LEVEL_COMPACTION时有效。 |
+|描述| 顺序空间内合并，开启顺序文件之间的合并 |
|类型| Boolean |
|默认值| true |
-|改后生效方式|仅开启合并后，重启服务生效|
+|改后生效方式|重启服务生效|
-* compaction\_interval
+* enable\_unseq\_space\_compaction
-|名字| compaction\_interval |
+|名字| enable\_unseq\_space\_compaction |
|:---:|:---|
-|描述| 设置延迟时间开始压缩任务，单位是：ms |
-|类型| Int32 |
-|默认值| 30000 |
-|改后生效方式|仅开启合并后，重启服务生效|
+|描述| 乱序空间内合并，开启乱序文件之间的合并 |
+|类型| Boolean |
+|默认值| false |
+|改后生效方式|重启服务生效|
-* seq\_file\_num\_in\_each\_level
+* enable\_cross\_space\_compaction
-|名字| seq\_file\_num\_in\_each\_level |
+|名字| enable\_cross\_space\_compaction |
|:---:|:---|
-|描述| 顺序每层级文件最大数 |
-|类型| Int32 |
-|默认值| 6 |
-|改后生效方式| 重启服务生效|
+|描述| 跨空间合并，开启将乱序文件合并到顺序文件中 |
+|类型| Boolean |
+|默认值| true |
+|改后生效方式|重启服务生效|
-* seq\_level\_num
+* cross\_compaction\_strategy
-|名字| seq\_level\_num |
+|名字| cross\_compaction\_strategy |
|:---:|:---|
-|描述| 顺序最大层级数 |
-|类型| Int32 |
-|默认值| 3 |
-|改后生效方式| 重启服务生效|
+|描述| 跨空间合并的策略 |
+|类型| String，暂时只有 INPLACE_COMPACTION 一个策略可选 |
+|默认值| inplace_compaction |
+|改后生效方式|重启服务生效|
-* unseq\_file\_num\_in\_each\_level
+* inner\_compaction\_strategy
-|名字| unseq\_file\_num\_in\_each\_level |
+|名字| cross\_compaction\_strategy |
|:---:|:---|
-|描述| 乱序每层级文件最大数 |
-|类型| Int32 |
-|默认值| 10 |
-|改后生效方式| 重启服务生效|
+|描述| 空间内合并的策略 |
+|类型| String，暂时只有 SIZE_TIERED_COMPACTION 一个策略可选 |
+|默认值| size_tiered_compaction |
+|改后生效方式|重启服务生效|
-* unseq\_level\_num
+* compaction\_priority
-|名字| unseq\_level\_num |
+|名字| compaction\_priority |
|:---:|:---|
-|描述| 乱序最大层级数 |
-|类型| Int32 |
-|默认值| 1 |
-|改后生效方式| 重启服务生效|
+|描述| 合并时的优先级，BALANCE 各种合并平等，INNER_CROSS 优先进行顺序文件和顺序文件或乱序文件和乱序文件的合并，CROSS_INNER
优先将乱序文件合并到顺序文件中 |
+|类型| String |
+|默认值| inner_cross，有 inner_cross、balance、cross_inner 三种可选 |
+|改后生效方式|重启服务生效|
-* max\_select\_unseq\_file\_num\_in\_each\_unseq\_compaction
+* target\_compaction\_file\_size
-|名字| max\_select\_unseq\_file\_num\_in\_each\_unseq\_compaction |
+|名字| target\_compaction\_file\_size |
|:---:|:---|
-|描述|
每个无序压缩任务中的最大打开文件数，仅当compaction_strategy为LEVEL_COMPACTION时有效。此参数必须远小于操作系统控制的每个进程允许的最大打开文件数（大多数系统为65535）。|
-|类型| Int32 |
-|默认值| 2000 |
-|改后生效方式| 重启服务生效|
+|描述| 空间内合并的目标文件大小 |
+|类型| Long，单位为字节|
+|默认值| 1073741824，即 1GB |
+|改后生效方式|重启服务生效|
-* merge\_chunk\_point\_number
+* max\_compaction\_candidate\_file\_num
-|名字| merge\_chunk\_point\_number |
+|名字| max\_compaction\_candidate\_file\_num |
|:---:|:---|
-|描述|
在目标文件中chunk的平均点数值达到值时，将文件合并到顶层。仅当compaction_strategy为LEVEL_COMPACTION时有效。在合并过程中，如果一个chunk的点数少于该参数，则该chunk将被与其后续的块合并，即使它没有溢出，直到合并的chunk到达这个阈值和新的块将被刷新。若小于0时，此机制将被禁用。|
-|类型| Int32 |
+|描述| 一次合并最多参与的文件数 |
+|类型| Integer |
+|默认值| 30，建议不要过小，过小容易导致系统性能变差 |
+|改后生效方式|重启服务生效|
+
+* target\_chunk\_size
+
+|名字| target\_chunk\_size |
+|:---:|:---|
+|描述| 合并时 Chunk 的目标大小 |
+|类型| Long，单位为字节|
+|默认值| 1048576，即 1MB |
+|改后生效方式|重启服务生效|
+
+* target\_chunk\_point\_num
+
+|名字| target\_chunk\_point\_num |
+|:---:|:---|
+|描述| 合并时 Chunk 的目标点数 |
+|类型| Integer |
|默认值| 100000 |
-|改后生效方式| 重启服务生效|
+|改后生效方式|重启服务生效|
-* merge\_page\_point\_number
+* chunk\_size\_lower\_bound\_in\_compaction
-|名字| merge\_page\_point\_number |
+|名字| chunk\_size\_lower\_bound\_in\_compaction |
|:---:|:---|
-|描述|
当一个页面的点数达到该值时，使用“追加合并”而不是“反序列化合并”。仅当compaction_strategy为LEVEL_COMPACTION时有效。|
-|类型| Int32 |
+|描述| 合并时源 Chunk 的大小小于这个值，将被解开成点进行合并 |
+|类型| Long，单位为字节 |
+|默认值| 128 |
+|改后生效方式|重启服务生效|
+
+* chunk\_point\_num\_lower\_bound\_in\_compaction
+
+|名字| chunk\_point\_num\_lower\_bound\_in\_compaction |
+|:---:|:---|
+|描述| 合并时源 Chunk 的点数小于这个值，将被解开成点进行合并 |
+|类型| Integer |
|默认值| 100 |
-|改后生效方式| 重启服务生效|
+|改后生效方式|重启服务生效|
-* merge\_chunk\_subthread\_num
+* compaction\_write\_throughput\_mb\_per\_sec\
-|名字| merge\_chunk\_subthread\_num |
+|名字| compaction\_write\_throughput\_mb\_per\_sec\ |
|:---:|:---|
-|描述| 设置多少个线程来执行乱序合并块子任务，默认为 4。若小于等于0时设置为1。|
-|类型| Int32 |
-|默认值| 4 |
-|改后生效方式| 重启服务生效|
+|描述| 合并时写入的速率，这个速率为所有线程的写入速率之和 |
+|类型| Integer，单位为 MB/s |
+|默认值| 8，建议不要设置的过大 |
+|改后生效方式|重启服务生效|
* merge\_fileSelection\_time\_budget
@@ -1666,6 +1716,7 @@ GC 日志默认是关闭的。为了性能调优，用户可能会需要收集 G
```bash
nohup sbin/start-server.sh printgc >/dev/null 2>&1 &
```
+
或者
```bash
diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties
b/server/src/assembly/resources/conf/iotdb-engine.properties
index 7572732..a51812f 100644
--- a/server/src/assembly/resources/conf/iotdb-engine.properties
+++ b/server/src/assembly/resources/conf/iotdb-engine.properties
@@ -413,7 +413,7 @@ timestamp_precision=ms
# unsequence space compaction: only compact the unsequence files
# Datatype: boolean
-# enable_unseq_space_compaction=true
+# enable_unseq_space_compaction=false
# cross space compaction: compact the unsequence files into the overlapped
sequence files
# Datatype: boolean
@@ -520,7 +520,7 @@ timestamp_precision=ms
# The limit of write throughput merge can reach per second
# Datatype: int
-# merge_write_throughput_mb_per_sec=8
+# compaction_write_throughput_mb_per_sec=8
# The maximum session idle time. unit: ms
# Idle sessions are the ones that performs neither query or non-query
operations for a period of time
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index f6b3483..48fe306 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -607,7 +607,7 @@ public class IoTDBConfig {
private boolean forceFullMerge = true;
/** The limit of compaction merge can reach per second */
- private int mergeWriteThroughputMbPerSec = 8;
+ private int compactionWriteThroughputMbPerSec = 8;
/**
* How many thread will be set up to perform compaction, 10 by default. Set
to 1 when less than or
@@ -1647,12 +1647,12 @@ public class IoTDBConfig {
insertMultiTabletEnableMultithreadingColumnThreshold;
}
- public int getMergeWriteThroughputMbPerSec() {
- return mergeWriteThroughputMbPerSec;
+ public int getCompactionWriteThroughputMbPerSec() {
+ return compactionWriteThroughputMbPerSec;
}
- public void setMergeWriteThroughputMbPerSec(int
mergeWriteThroughputMbPerSec) {
- this.mergeWriteThroughputMbPerSec = mergeWriteThroughputMbPerSec;
+ public void setCompactionWriteThroughputMbPerSec(int
compactionWriteThroughputMbPerSec) {
+ this.compactionWriteThroughputMbPerSec = compactionWriteThroughputMbPerSec;
}
public boolean isEnableMemControl() {
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 88fa824..bed2716 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
@@ -560,11 +560,11 @@ public class IoTDBDescriptor {
"max_compaction_candidate_file_num",
Integer.toString(conf.getMaxCompactionCandidateFileNum()))));
- conf.setMergeWriteThroughputMbPerSec(
+ conf.setCompactionWriteThroughputMbPerSec(
Integer.parseInt(
properties.getProperty(
- "merge_write_throughput_mb_per_sec",
- Integer.toString(conf.getMergeWriteThroughputMbPerSec()))));
+ "compaction_write_throughput_mb_per_sec",
+
Integer.toString(conf.getCompactionWriteThroughputMbPerSec()))));
conf.setEnablePartialInsert(
Boolean.parseBoolean(
@@ -1247,11 +1247,11 @@ public class IoTDBDescriptor {
properties.getProperty(
"slow_query_threshold",
Long.toString(conf.getSlowQueryThreshold()))));
// update merge_write_throughput_mb_per_sec
- conf.setMergeWriteThroughputMbPerSec(
+ conf.setCompactionWriteThroughputMbPerSec(
Integer.parseInt(
properties.getProperty(
"merge_write_throughput_mb_per_sec",
- Integer.toString(conf.getMergeWriteThroughputMbPerSec()))));
+
Integer.toString(conf.getCompactionWriteThroughputMbPerSec()))));
// update insert-tablet-plan's row limit for select-into
conf.setSelectIntoInsertTabletPlanRowLimit(
diff --git
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/manage/MergeManager.java
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/manage/MergeManager.java
index 9411b32..94e95c6 100644
---
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/manage/MergeManager.java
+++
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/manage/MergeManager.java
@@ -72,7 +72,8 @@ public class MergeManager implements IService,
MergeManagerMBean {
private MergeManager() {}
public RateLimiter getMergeWriteRateLimiter() {
-
setWriteMergeRate(IoTDBDescriptor.getInstance().getConfig().getMergeWriteThroughputMbPerSec());
+ setWriteMergeRate(
+
IoTDBDescriptor.getInstance().getConfig().getCompactionWriteThroughputMbPerSec());
return mergeWriteRateLimiter;
}
