This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 1ce2d78156 [Docs] Fix IoTDB, Http, Paimon, SelectDB, Neo4j and Phoenix
doc inaccuracies (#12758)
1ce2d78156 is described below
commit 1ce2d781566564d5bd603710e7442bd88c531414
Author: Jast <[email protected]>
AuthorDate: Mon Oct 19 15:01:04 2026 +0000
[Docs] Fix IoTDB, Http, Paimon, SelectDB, Neo4j and Phoenix doc
inaccuracies (#12758)
Co-authored-by: zhangshenghang <[email protected]>
---
docs/en/connectors/sink/SelectDB-Cloud.md | 2 ++
docs/en/connectors/source/Http.md | 4 ++--
docs/en/connectors/source/IoTDB.md | 2 +-
docs/en/connectors/source/IoTDBv2.md | 4 ++--
docs/en/connectors/source/Neo4j.md | 2 +-
docs/en/connectors/source/Phoenix.md | 2 +-
docs/en/transforms/jsonpath.md | 2 +-
docs/zh/connectors/sink/Paimon.md | 6 +++---
docs/zh/connectors/sink/SelectDB-Cloud.md | 2 ++
docs/zh/connectors/source/Http.md | 4 ++--
docs/zh/connectors/source/IoTDB.md | 4 ++--
docs/zh/connectors/source/IoTDBv2.md | 6 +++---
docs/zh/connectors/source/Neo4j.md | 2 +-
docs/zh/connectors/source/Phoenix.md | 2 +-
docs/zh/transforms/jsonpath.md | 2 +-
.../seatunnel/iotdbv2/source/IoTDBv2SourceSplitEnumerator.java | 2 +-
.../seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java | 2 +-
17 files changed, 27 insertions(+), 23 deletions(-)
diff --git a/docs/en/connectors/sink/SelectDB-Cloud.md
b/docs/en/connectors/sink/SelectDB-Cloud.md
index 80a7daa733..1a418a9d8d 100644
--- a/docs/en/connectors/sink/SelectDB-Cloud.md
+++ b/docs/en/connectors/sink/SelectDB-Cloud.md
@@ -46,6 +46,8 @@ Version Supported
| sink.max-retries | int | No | 3 | the max
retry times if writing records to database failed
|
| sink.buffer-size | int | No | 10 * 1024 * 1024 (10MB) | the
buffer size to cache data for stream load.
|
| sink.buffer-count | int | No | 10000 | the buffer
count to cache data for stream load.
|
+| sink.label-prefix | String | No | uuid | The unique
label prefix used by stream load. Defaults to a random UUID generated for each
job.
|
+| sink.flush.queue-size | int | No | 1 | Queue
length for async upload to object storage.
|
| selectdb.config | map | yes | - | This
option is used to support operations such as `insert`, `delete`, and `update`
when automatically generate sql,and supported formats.
|
## Data Type Mapping
diff --git a/docs/en/connectors/source/Http.md
b/docs/en/connectors/source/Http.md
index caedd1058e..7793608638 100644
--- a/docs/en/connectors/source/Http.md
+++ b/docs/en/connectors/source/Http.md
@@ -38,7 +38,7 @@ They can be downloaded via install-plugin.sh or from the
Maven central repositor
| Name | Type | Required | Default |
Description
|
|-------------------------------|---------|----------|-------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| url | String | Yes | - | Http
request url.
|
-| schema | Config | No | - | Http and
seatunnel data structure mapping. For more details, please refer to [Schema
Feature](../../introduction/concepts/schema-feature.md).
|
+| schema | Config | Conditional | - | Http
and seatunnel data structure mapping. Required when `format` is `json`. For
more details, please refer to [Schema
Feature](../../introduction/concepts/schema-feature.md).
|
| schema.fields | Config | No | - | The
schema fields of upstream data
|
| json_field | Config | No | - | This
parameter helps you configure the schema,so this parameter must be used with
schema.
|
| pageing | Config | No | - | This
parameter is used for paging queries
|
@@ -46,7 +46,7 @@ They can be downloaded via install-plugin.sh or from the
Maven central repositor
| pageing.use_placeholder_replacement | Boolean | No | false | If true, use
placeholder replacement (${field}) for headers, parameters and body values,
otherwise use key-based replacement.
|
| pageing.total_page_size | Long | No | 0 | This
parameter is used to control the total number of pages. `0` means the connector
continues until the returned row count is less than `pageing.batch_size`.
|
| pageing.batch_size | Int | No | 100 | The batch
size returned per request is used to determine whether to continue when the
total number of pages is unknown.
|
-| pageing.start_page_number | Int | No | 1 | Specify
the page number from which synchronization starts
|
+| pageing.start_page_number | Long | No | 1 | Specify
the page number from which synchronization starts
|
| pageing.page_type | String | No | PageNumber | this
parameter is used to specify the page type ,or PageNumber if not set, only
support `PageNumber` and `Cursor`. |
| pageing.cursor_field | String | No | - | this
parameter is used to specify the Cursor field name in the request parameter.
|
| pageing.cursor_response_field | String | No | - | This
parameter specifies the field in the response from which the cursor is
retrieved.
|
diff --git a/docs/en/connectors/source/IoTDB.md
b/docs/en/connectors/source/IoTDB.md
index aa26207c45..c159a07004 100644
--- a/docs/en/connectors/source/IoTDB.md
+++ b/docs/en/connectors/source/IoTDB.md
@@ -276,7 +276,7 @@ The data format loaded to SeaTunnelRow is as follows:
The split rule is:
-- If `num_partitions = 1`, the entire range `[lower_bound, upper_bound)` is
used as a single partition.
+- If `num_partitions = 1`, the entire range `[lower_bound, upper_bound]` is
used as a single partition.
- Otherwise the range is divided into `num_partitions` equal slices. If
`upper_bound - lower_bound < num_partitions`, the connector falls back to
`upper_bound - lower_bound` partitions.
For example, with `lower_bound = 1`, `upper_bound = 10`, and `num_partitions =
2` against the SQL `select * from test where age > 0 and age < 10`, the
connector generates:
diff --git a/docs/en/connectors/source/IoTDBv2.md
b/docs/en/connectors/source/IoTDBv2.md
index 2ae17edc1c..6196056b8c 100644
--- a/docs/en/connectors/source/IoTDBv2.md
+++ b/docs/en/connectors/source/IoTDBv2.md
@@ -17,7 +17,7 @@ Used to read data from IoTDB 2.x. The connector name in job
configuration is `Io
## Key features
- [x] [batch](../../introduction/concepts/connector-v2-features.md)
-- [x] [stream](../../introduction/concepts/connector-v2-features.md)
+- [ ] [stream](../../introduction/concepts/connector-v2-features.md)
- [x] [exactly-once](../../introduction/concepts/connector-v2-features.md)
- [x] [column projection](../../introduction/concepts/connector-v2-features.md)
> IoTDB allows column projection using SQL query.
@@ -85,7 +85,7 @@ the lower bound of the time range
```
split the time range into numPartitions parts
if numPartitions = 1, the whole time range will be used
- if numPartitions < (upper_bound - lower_bound), will use (upper_bound -
lower_bound) as numPartitions
+ if (upper_bound - lower_bound) < numPartitions, will use (upper_bound -
lower_bound) as numPartitions
eg: lower_bound = 1, upper_bound = 10, numPartitions = 2
sql = "select * from test where age > 0 and age < 10"
diff --git a/docs/en/connectors/source/Neo4j.md
b/docs/en/connectors/source/Neo4j.md
index 04ee0c9cc4..e98267143b 100644
--- a/docs/en/connectors/source/Neo4j.md
+++ b/docs/en/connectors/source/Neo4j.md
@@ -75,7 +75,7 @@ This source uses the existing driver
connection/authentication configuration and
## Notes
-- Use exactly one authentication method: username/password, bearer token, or
Kerberos ticket.
+- Configure at least one authentication method: username/password, bearer
token, or Kerberos ticket. If several are configured, username/password takes
precedence, followed by bearer token and Kerberos ticket.
- `query` controls which fields are returned. `schema.fields` must list the
returned field names and their SeaTunnel types.
- In multi-table mode, keep connection and authentication options at the root
level. Each `tables_configs` item defines one `query` and one `schema`.
- Every multi-table `schema` must set a unique `table`. Rows use this value as
their table ID for downstream routing.
diff --git a/docs/en/connectors/source/Phoenix.md
b/docs/en/connectors/source/Phoenix.md
index f68bb7b609..afe158d0d9 100644
--- a/docs/en/connectors/source/Phoenix.md
+++ b/docs/en/connectors/source/Phoenix.md
@@ -43,7 +43,7 @@ Supports standard SQL queries and column projection.
|----------------|--------|----------|---------------|----------------------------------------------------------------------------------------------------------|
| driver | String | Yes | - | JDBC driver class. Use
`org.apache.phoenix.jdbc.PhoenixDriver` for the thick driver, or
`org.apache.phoenix.queryserver.client.Driver` for the thin driver. |
| url | String | Yes | - | JDBC connection URL.
Use `jdbc:phoenix:localhost:2182/hbase` for the thick driver, or
`jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF` for the
thin driver. |
-| query | String | Yes | - | SELECT query executed
to read rows, for example `select age, name from test.source`. The column order
in the SELECT list must match `schema.fields`. |
+| query | String | Conditional | - | SELECT query
executed to read rows, for example `select age, name from test.source`. The
column order in the SELECT list must match `schema.fields`. Required unless
`table_path` or `table_list` is configured. |
| common-options | | No | - | Source plugin common
parameters, please refer to [Source Common
Options](../common-options/source-common-options.md) for details. |
### driver [string]
diff --git a/docs/en/transforms/jsonpath.md b/docs/en/transforms/jsonpath.md
index 66de4a84cc..69149b86f3 100644
--- a/docs/en/transforms/jsonpath.md
+++ b/docs/en/transforms/jsonpath.md
@@ -193,7 +193,7 @@ Then the data result table `fake1` will like this
| data | c1_string | c1_boolean | c1_integer |
c1_float | c1_double | c1_decimal | c1_date | c1_datetime |
c1_array | c1_map_array |
|------------------------------|------------------|------------|------------|----------|-----------|------------|------------|--------------|-----------------------------|------------------------------|
-| too much content not to show | this is a string | true | 42 |
3.14 | 3.14 | 10.55 | 2023-10-29 | 16:12:43.459 | ["item1",
"item2", "item3"] | [{"key1": "value1", "key2": "value2"}] |
+| too much content not to show | this is a string | true | 42 |
3.14 | 3.14 | 10.55 | 2023-10-29 | 16:12:43.459 | ["item1",
"item2", "item3"] | [{"c_string_1": "c_string_1", "c_string_2": "c_string_2",
"c_string_3": "c_string_3"}, {"c_string_1": "c_string_1", "c_string_2":
"c_string_2", "c_string_3": "c_string_3"}] |
## Read SeatunnelRow Example
diff --git a/docs/zh/connectors/sink/Paimon.md
b/docs/zh/connectors/sink/Paimon.md
index 902e40d7c6..cc817cf012 100644
--- a/docs/zh/connectors/sink/Paimon.md
+++ b/docs/zh/connectors/sink/Paimon.md
@@ -123,8 +123,8 @@ sink {
当您在批处理模式下将`checkpoint.interval`设置为大于0的值时，在写入一定数量的记录后checkpoint触发时，paimon连接器将把数据提交到paimon表。此时，写入的数据是可见的。
但是，如果您没有在批处理模式下设置`checkpoint.interval`，则在写入所有记录之后，paimon
sink连接器将提交数据。到批任务完成之前，写入的数据都是不可见的。
-## 更新日志
-你必须配置`changelog-producer=input`来启用paimon表的changelog产生模式。如果你使用了paimon
sink的自动建表功能，你可以在`paimon.table.write-props`或`table_options`中指定这个属性。
+## Changelog 生产者
+配置 `changelog-producer` 以启用 Paimon 表的 changelog 生产者模式。如果你使用了 Paimon sink
的自动建表功能，请在 `paimon.table.write-props` 或 `table_options` 中设置该属性；对于在 SeaTunnel
之外创建的已存在表，请直接在该表上设置。
Paimon表的changelog产生模式有[四种](https://paimon.apache.org/docs/master/primary-key-table/changelog-producer/)，分别是`none`、`input`、`lookup`
和 `full-compaction`。
@@ -139,7 +139,7 @@
Paimon表的changelog产生模式有[四种](https://paimon.apache.org/docs/mast
## 文件系统
Paimon连接器支持向多文件系统写入数据。目前支持的文件系统有hdfs和s3。
-如果您使用s3文件系统。您可以配置`fs.s3a.access-key `， `fs.s3a.secret-key`， `fs.s3a.endpoint`，
`fs.s3a.path.style.access`，
`fs.s3a.aws.credentials`。在`paimon.hadoop.conf`选项中设置提供程序的属性。
+如果您使用s3文件系统。您可以配置`fs.s3a.access-key `， `fs.s3a.secret-key`， `fs.s3a.endpoint`，
`fs.s3a.path.style.access`，
`fs.s3a.aws.credentials.provider`。在`paimon.hadoop.conf`选项中设置提供程序的属性。
除此之外，warehouse应该以`s3a://`开头。
## 模式演变
diff --git a/docs/zh/connectors/sink/SelectDB-Cloud.md
b/docs/zh/connectors/sink/SelectDB-Cloud.md
index 23ec152f22..6dcd375606 100644
--- a/docs/zh/connectors/sink/SelectDB-Cloud.md
+++ b/docs/zh/connectors/sink/SelectDB-Cloud.md
@@ -47,6 +47,8 @@ SelectDB Cloud 接收器连接器的内部实现是在批量缓存后上传数
| sink.max-retries | int | 否 | 3 |
写入数据库失败时的最大重试次数
|
| sink.buffer-size | int | 否 | 10 * 1024 * 1024 (10MB) |
用于流式加载的数据缓存缓冲区大小
|
| sink.buffer-count | int | 否 | 10000 |
用于流式加载的数据缓存缓冲区数量
|
+| sink.label-prefix | String | 否 | uuid | Stream load
使用的唯一 label 前缀，默认为每次作业随机生成的 UUID。
|
+| sink.flush.queue-size | int | 否 | 1 |
异步上传到对象存储的队列长度。
|
| selectdb.config | map | 是 | - | 此选项用于在自动生成
SQL 时支持 `insert`、`delete` 和 `update` 等操作，并支持多种格式。
|
## 数据类型映射
diff --git a/docs/zh/connectors/source/Http.md
b/docs/zh/connectors/source/Http.md
index 1d00d693d3..588e710e20 100644
--- a/docs/zh/connectors/source/Http.md
+++ b/docs/zh/connectors/source/Http.md
@@ -37,7 +37,7 @@ import ChangeLog from '../changelog/connector-http.md';
| 名称 | 类型 | 是否必须 | 默认值 | 描述
|
|-------------------------------|---------|----------|-------------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| url | String | 是 | - | Http 请求
URL。
|
-| schema | Config | 否 | - | Http 和
seatunnel 数据结构映射。更多详情请参考 [Schema
特性](../../introduction/concepts/schema-feature.md)。
|
+| schema | Config | 条件必填 | - | Http 和
seatunnel 数据结构映射。当 `format` 为 `json` 时必填。更多详情请参考 [Schema
特性](../../introduction/concepts/schema-feature.md)。
|
| schema.fields | Config | 否 | - | 上游数据的
schema 字段
|
| json_field | Config | 否 | - | 此参数帮助您配置
schema，因此此参数必须与 schema 一起使用。
|
| pageing | Config | 否 | - | 此参数用于分页查询
|
@@ -45,7 +45,7 @@ import ChangeLog from '../changelog/connector-http.md';
| pageing.use_placeholder_replacement | Boolean | 否 | false | 如果为
true，则使用占位符替换（${field}）用于 headers、parameters 和 body 值，否则使用基于键的替换。
|
| pageing.total_page_size | Long | 否 | 0 |
用于控制总页数。`0` 表示总页数未知，连接器会在返回行数小于 `pageing.batch_size` 时停止。
|
| pageing.batch_size | Int | 否 | 100 |
每个请求返回的批量大小，用于在总页数未知时判断是否继续。
|
-| pageing.start_page_number | Int | 否 | 1 | 指定同步开始的页码
|
+| pageing.start_page_number | Long | 否 | 1 | 指定同步开始的页码
|
| pageing.page_type | String | 否 | PageNumber |
此参数用于指定页面类型，如果未设置则为 PageNumber，仅支持 `PageNumber` 和 `Cursor`。
|
| pageing.cursor_field | String | 否 | - |
此参数用于指定请求参数中的游标字段名称。
|
| pageing.cursor_response_field | String | 否 | - |
此参数指定从中检索游标的响应字段。
|
diff --git a/docs/zh/connectors/source/IoTDB.md
b/docs/zh/connectors/source/IoTDB.md
index 94056365a6..5876c97119 100644
--- a/docs/zh/connectors/source/IoTDB.md
+++ b/docs/zh/connectors/source/IoTDB.md
@@ -67,7 +67,7 @@ import ChangeLog from '../changelog/connector-iotdb.md';
| fetch_size | int | 否 | - | 单次获取数据量：查询时每次从 IoTDB
获取的数据量 |
| lower_bound | long | 否 | - | 时间范围下界（通过时间列进行数据分片时使用）
|
| upper_bound | long | 否 | - | 时间范围上界（通过时间列进行数据分片时使用）
|
-| num_partitions | int | 否 | - |
分区数量（通过时间列进行数据分片时使用）：<br/> - 1 个分区：使用完整时间范围 <br/> - 若分区数 < (上界
-下界)，则使用差值作为实际分区数 |
+| num_partitions | int | 否 | - |
分区数量（通过时间列进行数据分片时使用）：<br/> - 1 个分区：使用完整时间范围 <br/> - 若 (上界 - 下界) <
分区数，则使用差值作为实际分区数 |
| thrift_default_buffer_size | int | 否 | - | Thrift 协议缓冲区大小
|
| thrift_max_frame_size | int | 否 | - | Thrift 最大帧尺寸
|
| enable_cache_leader | boolean | 否 | - | 是否启用 Leader 节点缓存
|
@@ -278,7 +278,7 @@ IoTDB> SELECT temperature, moisture, c_int, c_bigint,
c_float, c_double, c_strin
拆分规则：
-- 如果 `num_partitions = 1`，则整个范围 `[lower_bound, upper_bound)` 作为一个分片。
+- 如果 `num_partitions = 1`，则整个范围 `[lower_bound, upper_bound]` 作为一个分片。
- 否则把范围等分成 `num_partitions` 个分片。如果 `upper_bound - lower_bound <
num_partitions`，则回退为 `upper_bound - lower_bound` 个分片。
例如 `lower_bound = 1`、`upper_bound = 10`、`num_partitions = 2`，SQL 为 `select *
from test where age > 0 and age < 10`，会生成：
diff --git a/docs/zh/connectors/source/IoTDBv2.md
b/docs/zh/connectors/source/IoTDBv2.md
index 9c13bec33b..d8968cd8b6 100644
--- a/docs/zh/connectors/source/IoTDBv2.md
+++ b/docs/zh/connectors/source/IoTDBv2.md
@@ -17,7 +17,7 @@ import ChangeLog from '../changelog/connector-iotdb.md';
## 主要特性
- [x] [批处理](../../introduction/concepts/connector-v2-features.md)
-- [x] [流处理](../../introduction/concepts/connector-v2-features.md)
+- [ ] [流处理](../../introduction/concepts/connector-v2-features.md)
- [x] [精确一次](../../introduction/concepts/connector-v2-features.md)
- [x] [列投影](../../introduction/concepts/connector-v2-features.md)
> IoTDB 通过 SQL 查询支持列投影功能。
@@ -62,7 +62,7 @@ import ChangeLog from '../changelog/connector-iotdb.md';
| fetch_size | Integer | 否 | - | 单次请求从 IoTDB 获取的行数。
|
| lower_bound | Long | 否 | - | 时间范围下界（通过时间列进行数据分片时使用）
|
| upper_bound | Long | 否 | - | 时间范围上界（通过时间列进行数据分片时使用）
|
-| num_partitions | Integer | 否 | - |
分区数量（通过时间列进行数据分片时使用）：<br/> - 1 个分区：使用完整时间范围 <br/> - 若分区数 < (上界
-下界)，则使用差值作为实际分区数 |
+| num_partitions | Integer | 否 | - |
分区数量（通过时间列进行数据分片时使用）：<br/> - 1 个分区：使用完整时间范围 <br/> - 若 (上界 - 下界) <
分区数，则使用差值作为实际分区数 |
| default_thrift_buffer_size | Integer | 否 | - | IoTDB 客户端使用的默认 Thrift
缓冲区大小。 |
| max_thrift_frame_size | Integer | 否 | - | Thrift 最大帧尺寸
|
| enable_cache_leader | Boolean | 否 | - | 是否在 IoTDB 客户端启用 Leader
节点缓存。 |
@@ -86,7 +86,7 @@ import ChangeLog from '../changelog/connector-iotdb.md';
将时间范围分割成 numPartitions 个分区
若 numPartitions = 1，使用完整的时间范围
- 若 numPartitions < (upper_bound - lower_bound)，使用 (upper_bound -
lower_bound) 个分区
+ 若 (upper_bound - lower_bound) < numPartitions，使用 (upper_bound -
lower_bound) 个分区
例：lower_bound = 1, upper_bound = 10, numPartitions = 2
sql = "select * from test where age > 0 and age < 10"
diff --git a/docs/zh/connectors/source/Neo4j.md
b/docs/zh/connectors/source/Neo4j.md
index 161d106cf4..c956fc3f57 100644
--- a/docs/zh/connectors/source/Neo4j.md
+++ b/docs/zh/connectors/source/Neo4j.md
@@ -75,7 +75,7 @@ Source 复用现有驱动的连接和认证配置，并返回与正常 Source
## 注意事项
-- 认证方式只选一种：用户名密码、bearer token 或 Kerberos ticket。
+- 至少配置一种认证方式：用户名密码、bearer token 或 Kerberos ticket。若同时配置多种，优先级依次为用户名密码、bearer
token、Kerberos ticket。
- `query` 决定返回哪些字段，`schema.fields` 必须写清这些返回字段和对应类型。
- 多表模式下，连接和认证选项放在根级别；每个 `tables_configs` 配置项定义一个 `query` 和一个 `schema`。
- 每个多表 `schema` 必须设置唯一的 `table`，该值会作为数据行的表 ID，用于下游路由。
diff --git a/docs/zh/connectors/source/Phoenix.md
b/docs/zh/connectors/source/Phoenix.md
index d1457d5c8a..d237600206 100644
--- a/docs/zh/connectors/source/Phoenix.md
+++ b/docs/zh/connectors/source/Phoenix.md
@@ -44,7 +44,7 @@ import ChangeLog from '../changelog/connector-jdbc.md';
|----------------|--------|----------|--------|-------------------------------------------------------------------------------------------------|
| driver | String | 是 | - | JDBC 驱动类。thick 驱动使用
`org.apache.phoenix.jdbc.PhoenixDriver`，thin 驱动使用
`org.apache.phoenix.queryserver.client.Driver`。 |
| url | String | 是 | - | JDBC 连接 URL。thick 驱动使用
`jdbc:phoenix:localhost:2182/hbase`，thin 驱动使用
`jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF`。 |
-| query | String | 是 | - | 读取数据时执行的 SELECT 查询，例如 `select
age, name from test.source`。SELECT 列表的列顺序需要和 `schema.fields` 一致。 |
+| query | String | 条件必填 | - | 读取数据时执行的 SELECT 查询，例如 `select
age, name from test.source`。SELECT 列表的列顺序需要和 `schema.fields` 一致。未配置
`table_path` 或 `table_list` 时必填。 |
| common-options | | 否 | - | 源插件通用参数，详见 [Source
通用选项](../common-options/source-common-options.md)。 |
### driver [string]
diff --git a/docs/zh/transforms/jsonpath.md b/docs/zh/transforms/jsonpath.md
index 05e335616c..e7ba7d01e7 100644
--- a/docs/zh/transforms/jsonpath.md
+++ b/docs/zh/transforms/jsonpath.md
@@ -192,7 +192,7 @@ transform {
| data | c1_string | c1_boolean | c1_integer |
c1_float | c1_double | c1_decimal | c1_date | c1_datetime |
c1_array | c1_map_array |
|------------------------------|------------------|------------|------------|----------|-----------|------------|------------|--------------|-----------------------------|------------------------------|
-| too much content not to show | this is a string | true | 42 |
3.14 | 3.14 | 10.55 | 2023-10-29 | 16:12:43.459 | ["item1",
"item2", "item3"] | [{"key1": "value1", "key2": "value2"}] |
+| too much content not to show | this is a string | true | 42 |
3.14 | 3.14 | 10.55 | 2023-10-29 | 16:12:43.459 | ["item1",
"item2", "item3"] | [{"c_string_1": "c_string_1", "c_string_2": "c_string_2",
"c_string_3": "c_string_3"}, {"c_string_1": "c_string_1", "c_string_2":
"c_string_2", "c_string_3": "c_string_3"}] |
## 读取 SeatunnelRow 示例
diff --git
a/seatunnel-connectors-v2/connector-iotdb-v2/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdbv2/source/IoTDBv2SourceSplitEnumerator.java
b/seatunnel-connectors-v2/connector-iotdb-v2/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdbv2/source/IoTDBv2SourceSplitEnumerator.java
index b3bc5f6ada..8ccb1880cc 100644
---
a/seatunnel-connectors-v2/connector-iotdb-v2/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdbv2/source/IoTDBv2SourceSplitEnumerator.java
+++
b/seatunnel-connectors-v2/connector-iotdb-v2/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdbv2/source/IoTDBv2SourceSplitEnumerator.java
@@ -109,7 +109,7 @@ public class IoTDBv2SourceSplitEnumerator
/**
* split the time range into numPartitions parts if numPartitions is 1,
use the whole time range
- * if numPartitions < (end - start), use (start-end) partitions
+ * if (end - start) < numPartitions, use (end - start) partitions
*
* <p>eg: start = 1, end = 10, numPartitions = 2 sql = "select * from test
where age > 0 and age
* < 10"
diff --git
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java
index d7dd0674e1..2df733e243 100644
---
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java
+++
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java
@@ -111,7 +111,7 @@ public class IoTDBSourceSplitEnumerator
/**
* split the time range into numPartitions parts if numPartitions is 1,
use the whole time range
- * if numPartitions < (end - start), use (start-end) partitions
+ * if (end - start) < numPartitions, use (end - start) partitions
*
* <p>eg: start = 1, end = 10, numPartitions = 2 sql = "select * from test
where age > 0 and age
* < 10"
