This is an automated email from the ASF dual-hosted git repository. critas pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/iotdb-docs.git
The following commit(s) were added to refs/heads/main by this push:
new b17da365 add sink.batch.max-delay-ms in data sync (#755)
b17da365 is described below
commit b17da365ff6d983832be504e267fabba4da1e570
Author: leto-b <[email protected]>
AuthorDate: Wed Jun 4 14:59:49 2025 +0800
add sink.batch.max-delay-ms in data sync (#755)
* add sink.batch.max-delay-ms in data sync
* add sink.load-tsfile-strategy in data sync
* remove | batch.max-delay-ms |
在开启日志攒批发送模式时生效，表示一批数据在发送前的最长等待时间（单位：ms）
| Integer
| 选填 | 1 |
---
.../Master/Table/User-Manual/Data-Sync_apache.md | 54 +++++++++++-----------
.../Master/Table/User-Manual/Data-Sync_timecho.md | 31 +++++++------
.../latest-Table/User-Manual/Data-Sync_apache.md | 54 +++++++++++-----------
.../latest-Table/User-Manual/Data-Sync_timecho.md | 29 ++++++------
.../Master/Table/User-Manual/Data-Sync_apache.md | 8 ++--
.../Master/Table/User-Manual/Data-Sync_timecho.md | 7 ++-
.../latest-Table/User-Manual/Data-Sync_apache.md | 8 ++--
.../latest-Table/User-Manual/Data-Sync_timecho.md | 7 ++-
8 files changed, 109 insertions(+), 89 deletions(-)
diff --git a/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
b/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
index 85a2e321..819b6d12 100644
--- a/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
+++ b/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
@@ -531,35 +531,37 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **Parameter** | **Description**
| Value Range |
Required | Default Value |
-| :-------------------------- |
:----------------------------------------------------------- |
:----------------------------------------------------------- | :------- |
:------------ |
-| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
| String: iotdb-thrift-sink or iotdb-thrift-async-sink |
Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String |
No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No | -1 |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
#### iotdb-thrift-ssl-sink
-| **Parameter** | **Description**
| Value Range |
Required | Default Value |
-| :-------------------------- |
:----------------------------------------------------------- |
:----------------------------------------------------------- | :------- |
:------------ |
-| sink | iotdb-thrift-ssl-sink
| String: iotdb-thrift-ssl-sink |
Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String |
No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit. | Double: [Double.MIN_VALUE, Double.MAX_VALUE] | No
| -1 |
-| ssl.trust-store-path | Path to the trust store certificate for SSL
connection. | String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | Yes | -
|
-| ssl.trust-store-pwd | Password for the trust store certificate.
| Integer |
Yes | - |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-ssl-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
+| ssl.trust-store-path | Path to the trust store certificate for SSL
connection.
[...]
+| ssl.trust-store-pwd | Password for the trust store certificate.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
\ No newline at end of file
diff --git a/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
b/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
index b8c9c5b6..ced6d0af 100644
--- a/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
+++ b/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
@@ -194,7 +194,7 @@ Example Output:
```SQL
IoTDB> SHOW PIPEPLUGINS
-+---------------------+----------+-------------------------------------------------------------------------------------------------+---------+
+**+---------------------+----------+-------------------------------------------------------------------------------------------------+---------+
| PluginName|PluginType|
ClassName|PluginJar|
+---------------------+----------+-------------------------------------------------------------------------------------------------+---------+
| DO-NOTHING-PROCESSOR| Builtin|
org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.donothing.DoNothingProcessor|
|
@@ -581,18 +581,19 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **Parameter** | **Description**
| Value Range
| Required | Default Value |
-| :-------------------------- |
:-----------------------------------------------------------
|:---------------------------------------------------------------------------------|
:------- | :------------ |
-| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
| String: iotdb-thrift-sink or iotdb-thrift-async-sink
| Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String
| No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2
| No | "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No
| -1 |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
#### iotdb-air-gap-sink
@@ -606,12 +607,13 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
| compressor.zstd.level | When the selected RPC compression algorithm
is zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No | -1 |
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| air-gap.handshake-timeout-ms | The timeout duration for the handshake
requests when the sender and receiver attempt to establish a connection for the
first time, in milliseconds. | Integer
| No | 5000 |
#### iotdb-thrift-ssl-sink
| **Parameter** | **Description**
[...]
-| :--------------------------
|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
| sink | iotdb-thrift-ssl-sink
[...]
| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
@@ -622,6 +624,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| ssl.trust-store-path | Path to the trust store certificate for SSL
connection.
[...]
| ssl.trust-store-pwd | Password for the trust store certificate.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
diff --git a/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
b/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
index 85a2e321..819b6d12 100644
--- a/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
+++ b/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
@@ -531,35 +531,37 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **Parameter** | **Description**
| Value Range |
Required | Default Value |
-| :-------------------------- |
:----------------------------------------------------------- |
:----------------------------------------------------------- | :------- |
:------------ |
-| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
| String: iotdb-thrift-sink or iotdb-thrift-async-sink |
Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String |
No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No | -1 |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
#### iotdb-thrift-ssl-sink
-| **Parameter** | **Description**
| Value Range |
Required | Default Value |
-| :-------------------------- |
:----------------------------------------------------------- |
:----------------------------------------------------------- | :------- |
:------------ |
-| sink | iotdb-thrift-ssl-sink
| String: iotdb-thrift-ssl-sink |
Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String |
No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit. | Double: [Double.MIN_VALUE, Double.MAX_VALUE] | No
| -1 |
-| ssl.trust-store-path | Path to the trust store certificate for SSL
connection. | String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | Yes | -
|
-| ssl.trust-store-pwd | Password for the trust store certificate.
| Integer |
Yes | - |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-ssl-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
+| ssl.trust-store-path | Path to the trust store certificate for SSL
connection.
[...]
+| ssl.trust-store-pwd | Password for the trust store certificate.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
\ No newline at end of file
diff --git a/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
b/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
index cbc0dff0..ced6d0af 100644
--- a/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
+++ b/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
@@ -581,18 +581,19 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **Parameter** | **Description**
| Value Range
| Required | Default Value |
-| :-------------------------- |
:-----------------------------------------------------------
|:---------------------------------------------------------------------------------|
:------- | :------------ |
-| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
| String: iotdb-thrift-sink or iotdb-thrift-async-sink
| Yes | - |
-| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service). | String.
Example：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | Yes
| - |
-| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions. | String
| No | root |
-| password | Password for the username.
| String
| No | root |
-| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS. | Boolean: true, false
| No | true |
-| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission. | Integer
| No | 1 |
-| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission. | Long
| No | 16*1024*1024 |
-| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2
| No | "" |
-| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
-| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No
| -1 |
+| **Parameter** | **Description**
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| sink | iotdb-thrift-sink or iotdb-thrift-async-sink
[...]
+| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
+| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
+| password | Password for the username.
[...]
+| batch.enable | Enables batch mode for log transmission to
improve throughput and reduce IOPS.
[...]
+| batch.max-delay-seconds | Maximum delay (in seconds) for batch
transmission.
[...]
+| batch.size-bytes | Maximum batch size (in bytes) for batch
transmission.
[...]
+| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
+| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
+| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
#### iotdb-air-gap-sink
@@ -606,12 +607,13 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request. | String: snappy / gzip / lz4 / zstd / lzma2 | No
| "" |
| compressor.zstd.level | When the selected RPC compression algorithm
is zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm. | Int: [-131072, 22]
| No | 3 |
| rate-limit-bytes-per-second | The maximum number of bytes allowed to be
transmitted per second. The compressed bytes (such as after compression) are
calculated. If it is less than 0, there is no limit. | Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | No | -1 |
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| air-gap.handshake-timeout-ms | The timeout duration for the handshake
requests when the sender and receiver attempt to establish a connection for the
first time, in milliseconds. | Integer
| No | 5000 |
#### iotdb-thrift-ssl-sink
| **Parameter** | **Description**
[...]
-| :--------------------------
|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+|:----------------------------|:----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
| sink | iotdb-thrift-ssl-sink
[...]
| node-urls | URLs of the DataNode service ports on the
target IoTDB. (please note that the synchronization task does not support
forwarding to its own service).
[...]
| user/usename | Usename for connecting to the target IoTDB.
Must have appropriate permissions.
[...]
@@ -622,6 +624,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | The selected RPC compression algorithm.
Multiple algorithms can be configured and will be adopted in sequence for each
request.
[...]
| compressor.zstd.level | When the selected RPC compression algorithm is
zstd, this parameter can be used to additionally configure the compression
level of the zstd algorithm.
[...]
| rate-limit-bytes-per-second | Maximum bytes allowed per second for
transmission (calculated after compression). Set to a value less than 0 for no
limit.
[...]
+| load-tsfile-strategy | When synchronizing file data, whether the
receiver waits for the local load tsfile operation to complete before
responding to the sender:<br>sync: Wait for the local load tsfile
operation to complete before returning the response.<br>async: Do not wait
for the local load tsfile operation to complete; return the response
immediately.
[...]
| ssl.trust-store-path | Path to the trust store certificate for SSL
connection.
[...]
| ssl.trust-store-pwd | Password for the trust store certificate.
[...]
| format | The payload formats for data transmission
include the following options:<br> - hybrid: The format depends on what is
passed from the processor (either tsfile or tablet), and the sink performs no
conversion.<br> - tsfile: Data is forcibly converted to tsfile format before
transmission. This is suitable for scenarios like data file backup.<br> -
tablet: Data is forcibly converted to tsfile format before transmission. This
is useful for data synchronization [...]
diff --git a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
index d6ceaf72..74f178d8 100644
--- a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
+++ b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
@@ -534,13 +534,14 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填 |
-1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
#### iotdb-thrift-ssl-sink
-| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
-| ---------------------------
|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------|
-------- | ------------ |
+| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
+|-----------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------|
-------- | ------------ |
| sink | iotdb-thrift-ssl-sink
| String:
iotdb-thrift-ssl-sink | 必填
| - |
| node-urls | 目标端 IoTDB 任意多个 DataNode 节点的数据服务端口的
url（请注意同步任务不支持向自身服务进行转发）
|
String. 例：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667'
| 必填 | - |
| user/usename | 连接接收端使用的用户名，同步要求该用户具备相应的操作权限
| String
| 选填 |
root |
@@ -551,6 +552,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填
| -1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| ssl.trust-store-path | 连接目标端 DataNode 所需的 trust store 证书路径
| String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | 必填 | -
|
| ssl.trust-store-pwd | 连接目标端 DataNode 所需的 trust store 证书密码
| Integer
| 必填 | -
|
-| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
+| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 |
hybrid |
diff --git a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
index fb051630..2bb08670 100644
--- a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
+++ b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
@@ -575,8 +575,8 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **参数** | **描述**
| **value 取值范围**
| **是否必填** | **默认取值**
|
-| ---------------------------
|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------|
-------- | ------------ |
+| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
+|-----------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------|
-------- | ------------ |
| sink | iotdb-thrift-sink 或 iotdb-thrift-async-sink
| String:
iotdb-thrift-sink 或 iotdb-thrift-async-sink | 必填 | -
|
| node-urls | 目标端 IoTDB 任意多个 DataNode 节点的数据服务端口的
url（请注意同步任务不支持向自身服务进行转发）
|
String. 例：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | 必填
| - |
| user/usename | 连接接收端使用的用户名，同步要求该用户具备相应的操作权限
| String
| 选填 | root
|
@@ -587,6 +587,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填 | -1
|
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
@@ -601,6 +602,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用 |
String: snappy / gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072, 22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double: [Double.MIN_VALUE, Double.MAX_VALUE] | 选填 | -1
|
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| air-gap.handshake-timeout-ms | 发送端与接收端在首次尝试建立连接时握手请求的超时时长，单位：毫秒 | Integer
| 选填 | 5000 |
#### iotdb-thrift-ssl-sink
@@ -617,6 +619,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填
| -1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| ssl.trust-store-path | 连接目标端 DataNode 所需的 trust store 证书路径
| String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | 必填 | -
|
| ssl.trust-store-pwd | 连接目标端 DataNode 所需的 trust store 证书密码
| Integer
| 必填 | -
|
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
diff --git a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
index d6ceaf72..74f178d8 100644
--- a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
+++ b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
@@ -534,13 +534,14 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填 |
-1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
#### iotdb-thrift-ssl-sink
-| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
-| ---------------------------
|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------|
-------- | ------------ |
+| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
+|-----------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------|
-------- | ------------ |
| sink | iotdb-thrift-ssl-sink
| String:
iotdb-thrift-ssl-sink | 必填
| - |
| node-urls | 目标端 IoTDB 任意多个 DataNode 节点的数据服务端口的
url（请注意同步任务不支持向自身服务进行转发）
|
String. 例：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667'
| 必填 | - |
| user/usename | 连接接收端使用的用户名，同步要求该用户具备相应的操作权限
| String
| 选填 |
root |
@@ -551,6 +552,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填
| -1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| ssl.trust-store-path | 连接目标端 DataNode 所需的 trust store 证书路径
| String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | 必填 | -
|
| ssl.trust-store-pwd | 连接目标端 DataNode 所需的 trust store 证书密码
| Integer
| 必填 | -
|
-| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
+| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 |
hybrid |
diff --git a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
index fb051630..2bb08670 100644
--- a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
+++ b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
@@ -575,8 +575,8 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
#### iotdb-thrift-sink
-| **参数** | **描述**
| **value 取值范围**
| **是否必填** | **默认取值**
|
-| ---------------------------
|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------|
-------- | ------------ |
+| **参数** | **描述**
| **value 取值范围**
| **是否必填** |
**默认取值** |
+|-----------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------|
-------- | ------------ |
| sink | iotdb-thrift-sink 或 iotdb-thrift-async-sink
| String:
iotdb-thrift-sink 或 iotdb-thrift-async-sink | 必填 | -
|
| node-urls | 目标端 IoTDB 任意多个 DataNode 节点的数据服务端口的
url（请注意同步任务不支持向自身服务进行转发）
|
String. 例：'127.0.0.1：6667，127.0.0.1：6668，127.0.0.1：6669'， '127.0.0.1：6667' | 必填
| - |
| user/usename | 连接接收端使用的用户名，同步要求该用户具备相应的操作权限
| String
| 选填 | root
|
@@ -587,6 +587,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填 | -1
|
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
@@ -601,6 +602,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用 |
String: snappy / gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072, 22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double: [Double.MIN_VALUE, Double.MAX_VALUE] | 选填 | -1
|
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| air-gap.handshake-timeout-ms | 发送端与接收端在首次尝试建立连接时握手请求的超时时长，单位：毫秒 | Integer
| 选填 | 5000 |
#### iotdb-thrift-ssl-sink
@@ -617,6 +619,7 @@ pipe_all_sinks_rate_limit_bytes_per_second=-1
| compressor | 所选取的 rpc 压缩算法，可配置多个，对每个请求顺序采用
| String: snappy
/ gzip / lz4 / zstd / lzma2 | 选填 | ""
|
| compressor.zstd.level | 所选取的 rpc 压缩算法为 zstd 时，可使用该参数额外配置 zstd 算法的压缩等级
| Int: [-131072,
22] | 选填 | 3
|
| rate-limit-bytes-per-second | 每秒最大允许传输的 byte 数，计算压缩后的 byte（如压缩），若小于 0 则不限制
| Double:
[Double.MIN_VALUE, Double.MAX_VALUE] | 选填
| -1 |
+| load-tsfile-strategy | 文件同步数据时，接收端请求返回发送端前，是否等待接收端本地的 load tsfile
执行结果返回。<br>sync：等待本地的 load tsfile 执行结果返回；<br>async：不等待本地的 load tsfile 执行结果返回。
| String:
sync / async | 选填 | sync |
| ssl.trust-store-path | 连接目标端 DataNode 所需的 trust store 证书路径
| String.Example:
'127.0.0.1:6667,127.0.0.1:6668,127.0.0.1:6669', '127.0.0.1:6667' | 必填 | -
|
| ssl.trust-store-pwd | 连接目标端 DataNode 所需的 trust store 证书密码
| Integer
| 必填 | -
|
| format | 数据传输的payload格式， 可选项包括：<br> - hybrid： 取决于
processor 传递过来的格式（tsfile或tablet），sink不做任何转换。<br> -
tsfile：强制转换成tsfile发送，可用于数据文件备份等场景。<br> -
tablet：强制转换成tsfile发送，可用于发送端/接收端数据类型不完全兼容时的数据同步（以减少报错）。 | String: hybrid /
tsfile / tablet | 选填 | hybrid |
