Skip to content
Navigation Menu
Toggle navigation
Sign in
Appearance settings
Platform
AI CODE CREATION
GitHub Copilot
Write better code with AI
GitHub Spark
Build and deploy intelligent apps
GitHub Models
Manage and compare prompts
MCP Registry
New
Integrate external tools
DEVELOPER WORKFLOWS
Actions
Automate any workflow
Codespaces
Instant dev environments
Issues
Plan and track work
Code Review
Manage code changes
APPLICATION SECURITY
GitHub Advanced Security
Find and fix vulnerabilities
Code security
Secure your code as you build
Secret protection
Stop leaks before they start
EXPLORE
Why GitHub
Documentation
Blog
Changelog
Marketplace
View all features
Solutions
BY COMPANY SIZE
Enterprises
Small and medium teams
Startups
Nonprofits
BY USE CASE
App Modernization
DevSecOps
DevOps
CI/CD
View all use cases
BY INDUSTRY
Healthcare
Financial services
Manufacturing
Government
View all industries
View all solutions
Resources
EXPLORE BY TOPIC
AI
Software Development
DevOps
Security
View all topics
EXPLORE BY TYPE
Customer stories
Events & webinars
Ebooks & reports
Business insights
GitHub Skills
SUPPORT & SERVICES
Documentation
Customer support
Community forum
Trust center
Partners
Open Source
COMMUNITY
GitHub Sponsors
Fund open source developers
PROGRAMS
Security Lab
Maintainer Community
Accelerator
Archive Program
REPOSITORIES
Topics
Trending
Collections
Enterprise
ENTERPRISE SOLUTIONS
Enterprise platform
AI-powered developer platform
AVAILABLE ADD-ONS
GitHub Advanced Security
Enterprise-grade security features
Copilot for Business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
Pricing
Search or jump to...
Search code, repositories, users, issues, pull requests...
Search syntax tips
Provide feedback
Saved searches
Use saved searches to filter your results more quickly
Sign in
Sign up
Appearance settings
Resetting focus
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Dismiss alert
{{ message }}
apache
/
flink-cdc
Public
Notifications
You must be signed in to change notification settings
Fork
2.1k
Star
6.3k
Code
Issues
1
Pull requests
58
Discussions
Actions
Projects
0
Wiki
Security
Uh oh!
There was an error while loading.
Please reload this page
.
Insights
Additional navigation options
Code
Issues
Pull requests
Discussions
Actions
Projects
Wiki
Security
Insights
Commits
Branch selector
master
User selector
All users
Datepicker
All time
Commit History
Commits on Dec 16, 2025
[FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191)
yuxiqian
authored
f520424
Copy full SHA for f520424
Commits on Dec 10, 2025
[FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. (#4165)
5herhom
authored
c1a7d0b
Copy full SHA for c1a7d0b
Commits on Dec 9, 2025
[FLINK-38784][pipeline-connector][paimon] Bump Paimon version to 1.3.1 (#4189)
Show description for 2354f05
sd4324530
authored
2354f05
Copy full SHA for 2354f05
Commits on Dec 5, 2025
[FLINK-38737][common] Fix potential backwards incompatibility with fallback keys (#4185)
lvyanquan
authored
001cba0
Copy full SHA for 001cba0
[hotfix] Bump Doris flink connector version to 25.1.0 (#4188)
yuxiqian
authored
94e0c55
Copy full SHA for 94e0c55
Commits on Dec 2, 2025
[FLINK-35633] Add more YAML structure validations & provide better error messages (#4172)
yuxiqian
authored
8edc345
Copy full SHA for 8edc345
update markdown lint check (#4184)
Show description for 4b44b2f
kevinjqliu
authored
4b44b2f
Copy full SHA for 4b44b2f
Commits on Nov 26, 2025
[FLINK-38723][common/composer] Add getFlinkConf method to Context. (#4179)
lvyanquan
authored
7ad789e
Copy full SHA for 7ad789e
Commits on Nov 18, 2025
[FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171)
beryllw
authored
25fa95e
Copy full SHA for 25fa95e
[FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174)
tejanshrana
authored
55aff6e
Copy full SHA for 55aff6e
[FLINK-38618][base] Fix offset error due to duplicated stream split during TM failover if startup mode is latest-offset
Show description for 4bab367
gong
authored
4bab367
Copy full SHA for 4bab367
Commits on Nov 17, 2025
[FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism (#4150)
fcfangcc
authored
cfaf3cb
Copy full SHA for cfaf3cb
Commits on Nov 14, 2025
[FLINK-38279][mysql] Add SnapshotPendingSplitsState to MySQL checkpoint state during restoration
Show description for 6767d85
dwash96
and
yuxiqian
authored
6767d85
Copy full SHA for 6767d85
Commits on Nov 13, 2025
[FLINK-38568] [mysql-cdc] [cdc-base] Optimize binlog split lookup using binary search
Show description for 7a6bfd8
huyuanfeng2018
authored
7a6bfd8
Copy full SHA for 7a6bfd8
Commits on Nov 12, 2025
[FLINK-38680][build] Bump Flink 1.19 and 1.20 patch versions
Show description for 27dee1f
huyuanfeng2018
and
huyuanfeng
authored
27dee1f
Copy full SHA for 27dee1f
Commits on Nov 6, 2025
[FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while reporting metrics of Iceberg committer. (#4168)
fcfangcc
authored
6542026
Copy full SHA for 6542026
Commits on Oct 31, 2025
[FLINK-38478][pipeline-connector][paimon] Generate a random commit user and store it in state. (#4149)
lvyanquan
authored
6a18cd7
Copy full SHA for 6a18cd7
Commits on Oct 30, 2025
[FLINK-38593][test][sqlserver] Fix unstable sqlserver e2e tests via adding more time to wait SqlserverAgent Ready
Show description for 920fab9
leonardBang
authored
920fab9
Copy full SHA for 920fab9
Commits on Oct 28, 2025
[FLINK-38550][connect/mongodb] Allow recovery from more change stream expiration scenarios (#4161)
sjmittal
authored
4698b7a
Copy full SHA for 4698b7a
[FLINK-34735][docs] Translate "Developer Guide - Understanding Flink CDC API" Page to Chinese
Show description for c819525
edwardzcn-decade
authored
c819525
Copy full SHA for c819525
Commits on Oct 23, 2025
[FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission (#4158)
beryllw
authored
a62bae7
Copy full SHA for a62bae7
Commits on Oct 22, 2025
[FLINK-38540] Fix unintended object reuse in `TransformExpressionKey` (#4157)
Show description for 57726d2
yuxiqian
authored
57726d2
Copy full SHA for 57726d2
Commits on Oct 11, 2025
[FLINK-38496][docs] Icerberg YAML sink requires extra Hadoop jar to run (#4153)
loserwang1024
authored
7c7a74d
Copy full SHA for 7c7a74d
[FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly (#3892)
Show description for e0e0931
huyuanfeng2018
and
huyuanfeng
authored
e0e0931
Copy full SHA for e0e0931
Commits on Oct 9, 2025
[hotfix][docs] Update overview pages for connector version
Show description for 2850603
leonardBang
authored
2850603
Copy full SHA for 2850603
Commits on Oct 5, 2025
[FLINK-36631][source-connector][oracle] Add oracle read data by specific offset (#3675)
JNSimba
authored
a41423e
Copy full SHA for a41423e
Commits on Sep 30, 2025
[FLINK-38452] Fix unable to read incremental data from MongoDB collections with dots (`.`) (#4148)
Show description for 3559220
yuxiqian
authored
3559220
Copy full SHA for 3559220
Commits on Sep 29, 2025
[hotfix][ci] Run MongoDB tests with supported 7.0.x and 8.0.x images (#4147)
Show description for c7891ed
yuxiqian
authored
c7891ed
Copy full SHA for c7891ed
Commits on Sep 28, 2025
[FLINK-38440][pipeline-connector][iceberg] fixed the problem of writing SMALLINT/TINYINT data to Iceberg. (#4146)
fcfangcc
authored
682d791
Copy full SHA for 682d791
[FLINK-38232] [docs] Update the connector documentation to reflect the new features in Flink CDC 3.5.0 (#4102)
suhwan-cheon
authored
2fa6089
Copy full SHA for 2fa6089
Commits on Sep 25, 2025
[minor][hotfix][docs] Fluss use STRING rather than VARCHAR. (#4144)
loserwang1024
authored
6db99a6
Copy full SHA for 6db99a6
Commits on Sep 24, 2025
[minor][hotfix][docs] Fix some error in postgres yaml document. (#4140)
loserwang1024
authored
ab70a29
Copy full SHA for ab70a29
[FLINK-37199][doc] Update configuration in quickstart. (#3880)
lvyanquan
authored
83ef3de
Copy full SHA for 83ef3de
Commits on Sep 23, 2025
[build] Automate property replacement in pom.xml and exclude the release directory from license checks. (#4134)
lvyanquan
authored
3fb72cc
Copy full SHA for 3fb72cc
Commits on Sep 22, 2025
[FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect (#4133)
Mrart
authored
7bbfab0
Copy full SHA for 7bbfab0
Pagination
Previous
Next
You can’t perform that action at this time.