All pull requests

Pull requests

• [FLINK-41207][pipeline-connector/fluss] Preserve consumed offsets across empty log batches

  #4602·fxbing opened Oct 26, 2026Contributor·1 task done·

  ·

• [FLINK-41197][connect/mysql] Filter schema changes by captured table IDs

  mysql-cdc-connectormysql-pipeline-connector
  #4601·txjytxwd opened Oct 26, 2026·1 task done·

  ·

• [FLINK-41197][connect/mysql] Filter schema changes by captured table IDs (release-3.6)

  mysql-cdc-connectormysql-pipeline-connector
  #4600·txjytxwd opened Oct 26, 2026·1 task done·

  ·

• [FLINK-41107][pipeline-connector] Honor accepted schema evolution types in Hudi and MaxCompute sinks

  maxcompute-pipeline-connector
  #4599·YasuoStudyJava opened Oct 26, 2026·

  ·

• [FLINK-41201][pipeline-connector/fluss] Reuse sink writer metric group

  approvedreviewed
  #4598·fxbing opened Oct 26, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41057][iceberg] Fix append-only update and delete handling

  iceberg-pipeline-connector
  #4588·lvyanquan opened Oct 21, 2026Contributor·

  ·
  5

• [FLINK-38934][cdc connector mysql] honour ssl protocol setting configured in debeziumProps

  docsmysql-cdc-connectoroceanbase-cdc-connector
  #4583·watsonjo737 opened Oct 16, 2026·

  ·

• [FLINK-41011][pipeline-connector/doris] Keep NOT NULL constraint when creating Doris tables

  doris-pipeline-connector
  #4582·tchivs opened Oct 16, 2026Contributor·1 task done·

  ·

• [FLINK-41010][cdc-base] Roll back assigner status when failed snapshot splits are re-added

  base
  #4581·tchivs opened Oct 16, 2026Contributor·1 task done·

  ·

• [FLINK-41008][pipeline-connector/starrocks] Support multi-table transaction stream load

  docse2e-testsstarrocks-pipeline-connector
  #4579·sd4324530 opened Oct 15, 2026Contributor·1 task done·

  ·

• [FLINK-40966][pipeline-connector/fluss] Reuse metadata clients across schema operations

  runtime
  #4570·fxbing opened Oct 9, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces

  mongodb-cdc-connector
  #4568·LuanaMihailescu opened Oct 8, 2026·1 task·

  ·
  11

  

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

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

  ·

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

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

  ·
  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·1 task done·

  ·

• [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·1 task done·

  ·
  1

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

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

  ·
  22

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

  docsreviewed
  #4529·Admaing opened Sep 8, 2026·1 task·

  ·

• [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·1 task done·

  ·
  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·2 tasks done·

  ·
  11

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

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

  ·
  2

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

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

  ·
  1