All pull requests

Pull requests

• [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-41006][pipeline-connector/starrocks] Upgrade StarRocks Flink connector to 1.2.16

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

  ·

• [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent

  #4574·fxbing opened Oct 13, 2026Contributor·1 task done·

  ·
  6

• [FLINK-40973][pipeline-connector/fluss] Retry transient periodic discovery failures

  #4573·fxbing opened Oct 12, 2026Contributor·1 task done·

  ·
  4

• [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·

  ·

• [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset

  postgres-cdc-connector
  #4566·dev-donghwan opened Sep 30, 2026·

  ·
  10

• [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·

  ·

• [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-40560][postgres] Drop the replication slot when a snapshot-only source finishes

  approvedbasepostgres-cdc-connectorreviewed
  #4523·tchivs opened Sep 5, 2026Contributor·1 task done·

  ·
  12

• [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

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

  ·
  1

• [hotfix][postgres] generateCreateTableEvent result is skipped

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

  ·
  2

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

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

  ·