(seatunnel) branch dev updated: [Improve] Add conditional of start.mode with timestamp in mongo cdc option rule (#6770)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin 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 65ae7782c9 [Improve] Add conditional of start.mode with timestamp in 
mongo cdc option rule (#6770)
65ae7782c9 is described below

commit 65ae7782c9c9e56349f9ff6af6fbb57edaf44b35
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Sat May 11 13:12:01 2024 +0800

    [Improve] Add conditional of start.mode with timestamp in mongo cdc option 
rule (#6770)
---
 .../seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java      | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
index 07f85fa2a6..ede71f0f79 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java
@@ -28,6 +28,8 @@ import 
org.apache.seatunnel.api.table.factory.TableSourceFactory;
 import org.apache.seatunnel.api.table.factory.TableSourceFactoryContext;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
+import org.apache.seatunnel.connectors.cdc.base.option.SourceOptions;
+import org.apache.seatunnel.connectors.cdc.base.option.StartupMode;
 import 
org.apache.seatunnel.connectors.seatunnel.cdc.mongodb.config.MongodbSourceOptions;
 
 import com.google.auto.service.AutoService;
@@ -60,6 +62,10 @@ public class MongodbIncrementalSourceFactory implements 
TableSourceFactory {
                         
MongodbSourceOptions.INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB,
                         MongodbSourceOptions.STARTUP_MODE,
                         MongodbSourceOptions.STOP_MODE)
+                .conditional(
+                        MongodbSourceOptions.STARTUP_MODE,
+                        StartupMode.TIMESTAMP,
+                        SourceOptions.STARTUP_TIMESTAMP)
                 .build();
     }