This is an automated email from the ASF dual-hosted git repository.
wuchunfu pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from bd2b7c5599 [Hotfix][Core] Fix concurrency exceptions when
MultiTableSink#PrepareCommit (#7686)
add 9720f118e5 [Improve][Connector-V2] Optimize sqlserver package
structure (#7715)
No new revisions were added by this update.
Summary of changes:
.../{source => }/config/SqlServerSourceConfig.java | 2 +-
.../config/SqlServerSourceConfigFactory.java | 2 +-
.../source/{source => }/SqlServerDialect.java | 24 +++++++++++-----------
.../{source => }/SqlServerIncrementalSource.java | 6 +++---
.../SqlServerIncrementalSourceFactory.java | 2 +-
.../{source => }/SqlServerSourceOptions.java | 2 +-
.../enumerator/SqlServerChunkSplitter.java | 6 +++---
.../source/{source => }/offset/LsnOffset.java | 2 +-
.../{source => }/offset/LsnOffsetFactory.java | 10 ++++-----
.../fetch/SqlServerSourceFetchTaskContext.java | 18 ++++++++--------
.../SnapshotSplitChangeEventSourceContext.java | 4 ++--
.../fetch/scan/SqlServerSnapshotFetchTask.java | 6 +++---
.../fetch/scan/SqlServerSnapshotSplitReadTask.java | 6 +++---
.../SqlServerTransactionLogFetchTask.java | 12 +++++------
.../utils/SqlServerConnectionUtils.java | 2 +-
.../{source => }/utils/SqlServerSchema.java | 2 +-
.../{source => }/utils/SqlServerTypeUtils.java | 2 +-
.../{source => }/utils/SqlServerUtils.java | 4 ++--
.../{source => }/utils/TableDiscoveryUtils.java | 2 +-
.../SqlServerIncrementalSourceFactoryTest.java | 2 +-
.../{source => }/utils/SqlServerUtilsTest.java | 2 +-
21 files changed, 60 insertions(+), 58 deletions(-)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/config/SqlServerSourceConfig.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/config/SqlServerSourceConfigFactory.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/SqlServerDialect.java (85%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/SqlServerIncrementalSource.java (97%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/SqlServerIncrementalSourceFactory.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/SqlServerSourceOptions.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/enumerator/SqlServerChunkSplitter.java (94%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/offset/LsnOffset.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/offset/LsnOffsetFactory.java (88%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/reader/fetch/SqlServerSourceFetchTaskContext.java (95%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/reader/fetch/scan/SnapshotSplitChangeEventSourceContext.java (96%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/reader/fetch/scan/SqlServerSnapshotFetchTask.java (98%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/reader/fetch/scan/SqlServerSnapshotSplitReadTask.java (98%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/reader/fetch/transactionlog/SqlServerTransactionLogFetchTask.java (96%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/SqlServerConnectionUtils.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/SqlServerSchema.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/SqlServerTypeUtils.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/SqlServerUtils.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/TableDiscoveryUtils.java (99%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{source
=> }/SqlServerIncrementalSourceFactoryTest.java (98%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/{source
=> }/utils/SqlServerUtilsTest.java (99%)
