-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Pull requests: apache/flink-cdc
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark.
base
mysql-cdc-connector
mysql-pipeline-connector
#4101
opened Aug 19, 2025 by
loserwang1024
Loading…
[FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source.
mysql-cdc-connector
#4098
opened Aug 15, 2025 by
danzhewuju
Loading…
[FLINK-38218] Fix MySQL CDC binlog split metadata split transmission
mysql-cdc-connector
#4087
opened Aug 8, 2025 by
morozov
Loading…
[FLINK-37959][postgres]Supports all pgsql field types like debezium
reviewed
#4086
opened Aug 8, 2025 by
Mrart
Loading…
[draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema
debezium
mysql-cdc-connector
#4083
opened Aug 7, 2025 by
czy006
Loading…
[FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream.
3.5
common
paimon-pipeline-connector
reviewed
#4081
opened Aug 7, 2025 by
lvyanquan
Loading…
[pipeline-connector/paimon] Support table specific table.properties configuration
paimon-pipeline-connector
#4078
opened Aug 6, 2025 by
nickdelnano
Loading…
[minor][improvement] Add subdirectory scrapping to add all .jar in classpath
dist
#4071
opened Aug 2, 2025 by
CatOrLeader
Loading…
[FLINK-38139] Fix consecutive online schema change causes job failure.
mysql-cdc-connector
mysql-pipeline-connector
#4064
opened Jul 24, 2025 by
lvyanquan
Loading…
[FLINK-38079] Add Pipeline support for DateType and TimeType
#4060
opened Jul 10, 2025 by
proletarians
Loading…
[FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code
mysql-cdc-connector
#4048
opened Jun 21, 2025 by
morozov
Loading…
[improvement] adding runtime converter array
postgres-cdc-connector
#4042
opened Jun 10, 2025 by
iundarigun
Loading…
[FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted
base
db2-cdc-connector
mongodb-cdc-connector
mysql-cdc-connector
mysql-pipeline-connector
oracle-cdc-connector
postgres-cdc-connector
sqlserver-cdc-connector
#4041
opened Jun 10, 2025 by
linjianchang
Loading…
[Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka"
docs
Improvements or additions to documentation
#4033
opened Jun 2, 2025 by
Sukang1002
Loading…
[FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables
3.5
mysql-cdc-connector
mysql-pipeline-connector
#4032
opened May 30, 2025 by
zhyayun
Loading…
[FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization
3.5
docs
Improvements or additions to documentation
mysql-cdc-connector
mysql-pipeline-connector
#4027
opened May 24, 2025 by
yzeng1618
Loading…
[FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist
composer
#4024
opened May 22, 2025 by
aiwenmo
Loading…
[FLINK-37739][cli] fix flink-conf is not obtained in local mode
cli
composer
#4006
opened Apr 28, 2025 by
MOBIN-F
Loading…
[FLINK-37479][postgres] Add support for PARTITIONED TABLE
3.5
docs
Improvements or additions to documentation
postgres-cdc-connector
reviewed
#4004
opened Apr 26, 2025 by
phamvinh1712
Loading…
[FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector.
base
debezium
docs
Improvements or additions to documentation
oracle-cdc-connector
#3995
opened Apr 18, 2025 by
linjianchang
Loading…
[FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance
common
e2e-tests
#3994
opened Apr 18, 2025 by
joyCurry30
Loading…
Previous Next
ProTip!
Find all pull requests that aren't related to any open issues with -linked:issue.