Skip to content

[FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector#4320

Open
Daishuyuan wants to merge 2 commits intoapache:masterfrom
Daishuyuan:FLINK-39252
Open

[FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector#4320
Daishuyuan wants to merge 2 commits intoapache:masterfrom
Daishuyuan:FLINK-39252

Conversation

@Daishuyuan
Copy link

@Daishuyuan Daishuyuan commented Mar 17, 2026

What is changed

  • add a new SQL Server pipeline connector module with source provider, event deserializer, metadata accessor, schema/type utilities and factory wiring
  • integrate the new module into the pipeline connectors build and register the connector factory service
  • add coverage for full types, metadata access, online schema migration, parallel snapshot, newly added tables and table pattern matching
  • add the source-connector side updates needed by the pipeline connector integration

Why

Flink CDC currently has a source SQL Server connector but does not provide the corresponding pipeline connector. This change adds SQL Server pipeline connector support so SQL Server can be used in pipeline jobs consistently with other databases.

@Daishuyuan
Copy link
Author

Daishuyuan commented Mar 19, 2026

Hi @lvyanquan, @loserwang1024, could you help review this PR when you have time?

I have addressed the previous comment and updated the SQL Server pipeline connector implementation and tests accordingly. Thanks.

@Daishuyuan
Copy link
Author

Hi @yuxiqian, @leonardBang, this PR adds the SQL Server pipeline connector and also includes several source-side SQL Server changes. Could you help take a look when you have time? Thanks.

@leonardBang
Copy link
Contributor

Hi @yuxiqian, @leonardBang, this PR adds the SQL Server pipeline connector and also includes several source-side SQL Server changes. Could you help take a look when you have time? Thanks.

@Daishuyuan Thanks for the contribution! But we're going to code freeze soon and have no enough committers to help review this PR, considering this feature was not included in 3.6 roadmap, maybe we'd like to delivery this feature in next version.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants