This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12758-03f3f3e73a0db2835a682ee04f464c66503ba6ea in repository https://gitbox.apache.org/repos/asf/seatunnel.git
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"
