Skip to content

Commit 65ae778

Browse files
authored
[Improve] Add conditional of start.mode with timestamp in mongo cdc option rule (#6770)
1 parent 5189991 commit 65ae778

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/MongodbIncrementalSourceFactory.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,8 @@
2828
import org.apache.seatunnel.api.table.factory.TableSourceFactoryContext;
2929
import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
3030
import org.apache.seatunnel.api.table.type.SeaTunnelRow;
31+
import org.apache.seatunnel.connectors.cdc.base.option.SourceOptions;
32+
import org.apache.seatunnel.connectors.cdc.base.option.StartupMode;
3133
import org.apache.seatunnel.connectors.seatunnel.cdc.mongodb.config.MongodbSourceOptions;
3234

3335
import com.google.auto.service.AutoService;
@@ -60,6 +62,10 @@ public OptionRule optionRule() {
6062
MongodbSourceOptions.INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB,
6163
MongodbSourceOptions.STARTUP_MODE,
6264
MongodbSourceOptions.STOP_MODE)
65+
.conditional(
66+
MongodbSourceOptions.STARTUP_MODE,
67+
StartupMode.TIMESTAMP,
68+
SourceOptions.STARTUP_TIMESTAMP)
6369
.build();
6470
}
6571

0 commit comments

Comments
 (0)