All pull requests

Pull requests

• [FLINK-40514][docs][pipeline-connector/doris] Align Doris pipeline connector option table with implementation

  docs
  #4561·suntectec opened Sep 26, 2026Contributor·

  ·

• [FLINK-40795][cdc-runtime] Fix re-added table with drifted schema not being re-created downstream

  commonruntime
  #4560·sd4324530 opened Sep 24, 2026Contributor·

  ·

• [FLINK-40783][build] Upgrade HikariCP from 4.0.3 to 7.1.0

  basebuildmysql-cdc-connector
  #4559·sd4324530 opened Sep 23, 2026Contributor·

  ·

• [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery

  #4555·fxbing opened Sep 22, 2026Contributor·

  ·

• [FLINK-40679][pipeline-connector/iceberg] Support Iceberg table maintenance

  commoncomposerdocse2e-testsiceberg-pipeline-connectormysql-pipeline-connectorpostgres-pipeline-connector
  #4544·zml1206 opened Sep 16, 2026Contributor·

  ·
  2

  

• [FLINK-40650][cdc-connector][sqlserver] Improve SqlServerDialect.discoverDataCollectionSchemas to reduce snapshot start time with many tables

  sqlserver-cdc-connector
  #4543·stefanofrancoscania opened Sep 15, 2026·

  ·

• [hotfix][cdc-composer] Fix "URI is not hierarchical" when resolving factory JAR path

  composer
  #4542·wangmingzhou1986 opened Sep 15, 2026·

  ·

• [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector

  builddocs
  #4533·suntectec opened Sep 12, 2026Contributor·

  ·

• [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime

  commoncomposere2e-testspostgres-pipeline-connectorruntime
  #4530·tchivs opened Sep 8, 2026Contributor·

  ·
  16

• [FLINK-40532][docs] Remove experimental warning from scan.parse.online.schema.changes.enabled

  docsreviewed
  #4529·Admaing opened Sep 8, 2026·

  ·

• [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes

  postgres-cdc-connector
  #4523·tchivs opened Sep 5, 2026Contributor·

  ·

• [FLINK-40538][postgres] Skip WAL position search on idle publication …

  postgres-cdc-connector
  #4521·eskabetxe opened Sep 2, 2026Member·

  ·

• [FLINK-35104] [pipeline-connector/kafka]support pipeline kafka source

  buildcommoncomposerdocse2e-testskafka-pipeline-connectorpaimon-pipeline-connectorruntimestarrocks-pipeline-connector
  #4518·MOBIN-F opened Aug 31, 2026Contributor·

  ·
  1

• [FLINK-36605] Bump debezium to last 2.x version

  basebuilddb2-cdc-connectordebeziume2e-testsmysql-cdc-connectormysql-pipeline-connectoroceanbase-cdc-connectororacle-cdc-connectorpostgres-cdc-connectorpostgres-pipeline-connectorsqlserver-cdc-connectorvitess-cdc-connector
  #4516·eskabetxe opened Aug 28, 2026Member·

  ·
  2

• [oracle] Support specific-offset startup mode with SCN for Oracle pipeline source

  #4510·fightBoxing opened Aug 18, 2026·

  ·

• [FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader

  docsmysql-cdc-connectormysql-pipeline-connector
  #4509·hadoopkandy opened Aug 17, 2026·

  ·
  11

• [FLINK-40432][connect/tidb] Split key ranges by TiKV region via FLIP-27 enumerator

  docstidb-cdc-connector
  #4508·lifulong opened Aug 17, 2026·

  ·
  2

• [FLINK-40385][postgre]Optimize efficiency issues of PostgreSQL during the full snapshot phase.

  postgres-cdc-connector
  #4506·hql0312 opened Aug 12, 2026Contributor·

  ·
  1

• [mysql] Preserve schema for no-op CREATE TABLE IF NOT EXISTS ... LIKE

  mysql-pipeline-connector
  #4502·lelovelo opened Aug 7, 2026·

  ·

• [FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source

  #4497·leosanqing opened Aug 4, 2026·

  ·
  1

• [hotfix][postgres] generateCreateTableEvent result is skipped

  postgres-pipeline-connector
  #4490·CatOrLeader opened Jul 24, 2026Contributor·

  ·
  1

• [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent

  base
  #4489·dev-donghwan opened Jul 24, 2026·

  ·

• [cdc-connector][oracle] Support row_id metadata column and fix headers loss in JdbcSourceFetchTaskContext

  baseoracle-cdc-connector
  #4487·fightBoxing opened Jul 24, 2026·

  ·

• [oracle] Support row_id metadata column for Oracle CDC (with headers-loss bug fix)

  #4486·fightBoxing opened Jul 24, 2026·

  ·

• [FLINK-40203][runtime] Add an explicit option for Flink SQL-compatible YAML Transform expression semantics

  clicommoncomposerdocsruntime
  #4484·haruki-830 opened Jul 23, 2026Contributor·

  ·
  7