This is an automated email from the ASF dual-hosted git repository.
lidongdai 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 5b7cdd2b67 [Fix][Connecotr][MongoDB]Fix mongodb maxtime naming (#10267)
5b7cdd2b67 is described below
commit 5b7cdd2b67e71b1de1ab29e34176427bb9e6f81f
Author: Jast <[email protected]>
AuthorDate: Mon Jan 5 21:04:32 2026 +0800
[Fix][Connecotr][MongoDB]Fix mongodb maxtime naming (#10267)
---
docs/en/connector-v2/source/MongoDB.md | 2 +-
docs/zh/connector-v2/source/MongoDB.md | 2 +-
.../seatunnel/mongodb/config/MongodbSourceOptions.java | 4 ++--
.../connectors/seatunnel/mongodb/source/MongodbSource.java | 2 +-
.../seatunnel/mongodb/source/config/MongodbReadOptions.java | 10 +++++-----
.../seatunnel/mongodb/source/reader/MongodbReader.java | 2 +-
6 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/docs/en/connector-v2/source/MongoDB.md
b/docs/en/connector-v2/source/MongoDB.md
index e9b6f54f45..cedda293cd 100644
--- a/docs/en/connector-v2/source/MongoDB.md
+++ b/docs/en/connector-v2/source/MongoDB.md
@@ -79,7 +79,7 @@ For specific types in MongoDB, we use Extended JSON format to
map them to SeaTun
| partition.split-size | Long | No | 64 * 1024 * 1024 | The size of
Mongodb fragment.
|
| cursor.no-timeout | Boolean | No | true | MongoDB
server normally times out idle cursors after an inactivity period (10 minutes)
to prevent excess memory use. Set this option to true to prevent that. However,
if the application takes longer than 30 minutes to process the current batch of
documents, the session is marked as expired and closed. |
| fetch.size | Int | No | 2048 | Set the
number of documents obtained from the server for each batch. Setting the
appropriate batch size can improve query performance and avoid the memory
pressure caused by obtaining a large amount of data at one time.
|
-| max.time-min | Long | No | 600 | This
parameter is a MongoDB query option that limits the maximum execution time for
query operations. The value of maxTimeMin is in Minute. If the execution time
of the query exceeds the specified time limit, MongoDB will terminate the
operation and return an error. |
+| max.time-min | Long | No | 10 | This
parameter is a MongoDB query option that limits the maximum execution time for
query operations. The value of maxTimeMin is in minutes. If the execution time
of the query exceeds the specified time limit, MongoDB will terminate the
operation and return an error. |
| flat.sync-string | Boolean | No | true | By utilizing
flatSyncString, only one field attribute value can be set, and the field type
must be a String. This operation will perform a string mapping on a single
MongoDB data entry.
|
| common-options | | No | - | Source plugin
common parameters, please refer to [Source Common
Options](../source-common-options.md) for details
|
diff --git a/docs/zh/connector-v2/source/MongoDB.md
b/docs/zh/connector-v2/source/MongoDB.md
index bd98da0bcf..64e14422ce 100644
--- a/docs/zh/connector-v2/source/MongoDB.md
+++ b/docs/zh/connector-v2/source/MongoDB.md
@@ -79,7 +79,7 @@ MongoDB连接器提供了从MongoDB读取数据和向MongoDB写入数据的能
| partition.split-size | Long | 否 | 64 * 1024 * 1024 | 分片大小。
|
| cursor.no-timeout | Boolean | 否 | true |
MongoDB服务器通常在非活动期（10分钟）后超时空闲游标，以防止过度使用内存。将此选项设置为true以防止这种情况发生。但是，如果应用程序处理当前一批文档的时间超过30分钟，则会话将标记为已过期并关闭。
|
| fetch.size | Int | 否 | 2048 |
设置每批从服务器获取的文档数量。设置适当的批大小可以提高查询性能，避免一次获取大量数据造成的内存压力。
|
-| max.time-min | Long | 否 | 600 |
此参数是一个MongoDB查询选项，用于限制查询操作的最大执行时间。maxTimeMin的值以分钟为单位。如果查询的执行时间超过指定的时间限制，MongoDB将终止操作并返回错误。
|
+| max.time-min | Long | 否 | 10 |
此参数是一个MongoDB查询选项，用于限制查询操作的最大执行时间。maxTimeMin的值以分钟为单位。如果查询的执行时间超过指定的时间限制，MongoDB将终止操作并返回错误。
|
| flat.sync-string | Boolean | 否 | true |
通过使用flatSyncString，只能设置一个字段属性值，字段类型必须是String。此操作将对单个MongoDB数据条目执行字符串映射。
|
| common-options | | 否 | - | 源插件常用参数，请参考
[源通用选项](../source-common-options.md)
|
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbSourceOptions.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbSourceOptions.java
index 766d25f62e..d62a0456f7 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbSourceOptions.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/config/MongodbSourceOptions.java
@@ -64,9 +64,9 @@ public class MongodbSourceOptions extends MongodbBaseOptions {
public static final Option<Long> MAX_TIME_MIN =
Options.key("max.time-min")
.longType()
- .defaultValue(600L)
+ .defaultValue(10L)
.withDescription(
- "This parameter is a MongoDB query option that
limits the maximum execution time for query operations. The value of maxTimeMS
is in milliseconds. If the execution time of the query exceeds the specified
time limit, MongoDB will terminate the operation and return an error.");
+ "This parameter is a MongoDB query option that
limits the maximum execution time for query operations. The value of maxTimeMin
is in minutes. If the execution time of the query exceeds the specified time
limit, MongoDB will terminate the operation and return an error.");
public static final Option<Boolean> FLAT_SYNC_STRING =
Options.key("flat.sync-string")
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java
index e1906a1a20..90b265e75e 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java
@@ -132,7 +132,7 @@ public class MongodbSource
private MongodbReadOptions createMongodbReadOptions(ReadonlyConfig config)
{
MongodbReadOptions.MongoReadOptionsBuilder mongoReadOptionsBuilder =
MongodbReadOptions.builder();
-
mongoReadOptionsBuilder.setMaxTimeMS(config.get(MongodbSourceOptions.MAX_TIME_MIN));
+
mongoReadOptionsBuilder.setMaxTimeMin(config.get(MongodbSourceOptions.MAX_TIME_MIN));
mongoReadOptionsBuilder.setFetchSize(config.get(MongodbSourceOptions.FETCH_SIZE));
mongoReadOptionsBuilder.setNoCursorTimeout(
config.get(MongodbSourceOptions.CURSOR_NO_TIMEOUT));
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
index 61dd66ad8f..5644bf129d 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
@@ -37,12 +37,12 @@ public class MongodbReadOptions implements Serializable {
private final boolean noCursorTimeout;
- private final long maxTimeMS;
+ private final long maxTimeMin;
- private MongodbReadOptions(int fetchSize, boolean noCursorTimeout, long
maxTimeMS) {
+ private MongodbReadOptions(int fetchSize, boolean noCursorTimeout, long
maxTimeMin) {
this.fetchSize = fetchSize;
this.noCursorTimeout = noCursorTimeout;
- this.maxTimeMS = maxTimeMS;
+ this.maxTimeMin = maxTimeMin;
}
public static MongoReadOptionsBuilder builder() {
@@ -71,8 +71,8 @@ public class MongodbReadOptions implements Serializable {
return this;
}
- public MongoReadOptionsBuilder setMaxTimeMS(long maxTimeMS) {
- this.maxTimeMin = maxTimeMS;
+ public MongoReadOptionsBuilder setMaxTimeMin(long maxTimeMin) {
+ this.maxTimeMin = maxTimeMin;
return this;
}
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
index 84f7575ad5..543e1b345a 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
@@ -120,7 +120,7 @@ public class MongodbReader implements
SourceReader<SeaTunnelRow, MongoSplit> {
.projection(split.getProjection())
.batchSize(readOptions.getFetchSize())
.noCursorTimeout(readOptions.isNoCursorTimeout())
- .maxTime(readOptions.getMaxTimeMS(), TimeUnit.MINUTES)
+ .maxTime(readOptions.getMaxTimeMin(), TimeUnit.MINUTES)
.iterator();
}
