This is an automated email from the ASF dual-hosted git repository.
ic4y pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from d3b59d88c [Hotfix] Fix the CI Job name error (#5032)
add 6d9a3e595 [Feature][CDC] Support disable/enable exactly once for
INITIAL (#4921)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/source/MySQL-CDC.md | 5 ++
docs/en/connector-v2/source/SqlServer-CDC.md | 5 ++
.../cdc/base/config/BaseSourceConfig.java | 3 ++
.../cdc/base/config/JdbcSourceConfig.java | 4 +-
.../cdc/base/config/JdbcSourceConfigFactory.java | 4 ++
.../connectors/cdc/base/config/SourceConfig.java | 2 +
.../connectors/cdc/base/option/SourceOptions.java | 6 +++
.../enumerator/IncrementalSplitAssigner.java | 36 +++++++++----
.../source/enumerator/SnapshotSplitAssigner.java | 15 ++----
.../cdc/base/source/enumerator/SplitAssigner.java | 3 +-
.../enumerator/state/SnapshotPhaseState.java | 6 +--
.../base/source/event/SnapshotSplitWatermark.java | 1 +
.../source/reader/IncrementalSourceReader.java | 5 +-
.../reader/IncrementalSourceRecordEmitter.java | 4 ++
.../cdc/base/source/reader/external/FetchTask.java | 2 +
.../external/IncrementalSourceScanFetcher.java | 13 +++--
.../external/IncrementalSourceStreamFetcher.java | 12 ++++-
.../external/JdbcSourceFetchTaskContext.java | 5 ++
.../source/split/CompletedSnapshotSplitInfo.java | 15 ++++--
.../cdc/base/source/split/SnapshotSplit.java | 14 ++++-
.../source/split/state/SnapshotSplitState.java | 2 +
.../cdc/mysql/config/MySqlSourceConfig.java | 6 ++-
.../cdc/mysql/config/MySqlSourceConfigFactory.java | 3 +-
.../source/MySqlIncrementalSourceFactory.java | 4 ++
.../mysql/source/eumerator/MySqlChunkSplitter.java | 2 +-
.../reader/fetch/scan/MySqlSnapshotFetchTask.java | 52 ++++++++++++-------
.../fetch/scan/MySqlSnapshotSplitReadTask.java | 15 +++---
.../source/config/SqlServerSourceConfig.java | 6 ++-
.../config/SqlServerSourceConfigFactory.java | 3 +-
.../source/SqlServerIncrementalSourceFactory.java | 4 ++
.../source/eumerator/SqlServerChunkSplitter.java | 2 +-
.../fetch/scan/SqlServerSnapshotFetchTask.java | 59 ++++++++++++----------
.../fetch/scan/SqlServerSnapshotSplitReadTask.java | 15 +++---
33 files changed, 226 insertions(+), 107 deletions(-)
