Google Git Google Git
Sign in
apache/flink-cdc/HEAD
  1. 9ea8bf0 [FLINK-41028] Support data lake table properties in the Fluss pipeline sink (#4584) by Hongshun Wang · 23 hours ago master
  2. c430d39 [hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) by yuxiqian · 24 hours ago
  3. d9766a3 [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent (#4489) by 김동환 · 31 hours ago
  4. 5f05001 [FLINK-41082] Polish Flink CDC docs and fix format issues (#4589) by yuxiqian · 31 hours ago
  5. d919dcc [docs] Correct Debezium version in DataStream API package guidance (#4591) by Hang Ruan · 2 days ago
  6. 24d08ea [FLINK-41058][pipeline-connector/fluss] Merge schema options with global sink table properties when creating tables. (#4587) by Hongshun Wang · 3 days ago
  7. c1998ea [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent (#4574) by Xiaobing Fang · 3 days ago
  8. 3a0b768 [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset (#4566) by 김동환 · 3 days ago
  9. abf18d7 [FLINK-41006][pipeline-connector/starrocks] Upgrade StarRocks Flink connector to 1.2.16 (#4578) by Pei Yu · 8 days ago
  10. efb1d3a [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes (#4523) by Lanny Boarts · 8 days ago
  11. 93d868c [FLINK-40983][docs] Document Kafka sink.delivery-guarantee (#4575) by Rango · 9 days ago
  12. 36fee43 [FLINK-40994][connect/paimon] Upgrade Paimon SDK to 2.1.0 (#4577) by Pei Yu · 9 days ago
  13. b11c961 [FLINK-38907][postgres] Fix data loss with filtered publication autocreate mode in backfill phase (#4223) by Giovanny Gutiérrez · 10 days ago
  14. c09440c [docs] Update docs for release 3.7.0 (#4576) by Pei Yu · 10 days ago
  15. 1c9f2aa [legal] Update NOTICE for bundled dependencies (#4565) by yuxiqian · 11 days ago
  16. 062ad34 [FLINK-40538][postgres] Skip WAL position search on idle publication for a fresh start (#4521) by Joao Boto · 12 days ago
  17. f24e808 [FLINK-40850][pipeline-connector/fluss] Accept custom bucket keys in pre-created primary-key tables (#4564) by Xiaobing Fang · 2 weeks ago
  18. c87d80c [FLINK-40951][docs] Translate Flink source connector docs into Chinese (#4567) by Pei Yu · 2 weeks ago
  19. 25e9862 [hotfix][connect/mysql] Pin Percona Toolkit image for OSC tests (#4571) by yuxiqian · 2 weeks ago
  20. 68ae522 [build] Bump version to 3.8-SNAPSHOT (#4563) by yuxiqian · 2 weeks ago
  21. 4b67882 [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery (#4555) by Xiaobing Fang · 4 weeks ago
  22. f167097 [FLINK-36581][cli] Allow specifying Flink configuration in YAML job file (#3918) by MOBIN · 4 weeks ago
  23. fe2aa40 [FLINK-40739][maxcompute] Fix partition handling for sink writes (#4562) by Kunni · 4 weeks ago
  24. 7963bea [FLINK-40514][docs] Add missing Doris pipeline connector options (#4561) by suntectec · 4 weeks ago
  25. eef77bb [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation (#4540) by haruki · 4 weeks ago
  26. 6599fc2 [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. (#4214) by Kunni · 4 weeks ago
  27. 375597f [FLINK-40575][pipeline-connector/fluss] Support dynamic table unsubscription and re-subscription (#4527) by Xiaobing Fang · 4 weeks ago
  28. a87b2db [FLINK-39315][cdc-connector][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill (#4334) by chengcongchina · 4 weeks ago
  29. e4aa8f9 [FLINK-40646][Postgres] Pooled JDBC connections use the default application name. by Hongshun Wang · 4 weeks ago
  30. 15cb218 [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL (#4308) by Mingliang Zhu · 4 weeks ago
  31. 405d914 [hotfix][runtime] Fix occasional Janino initialization race error (#4558) by yuxiqian · 4 weeks ago
  32. 391169d [hotfix][runtime Preserve original failure during distributed schema evolution (#4556) by yuxiqian · 4 weeks ago
  33. 5b5d1db [FLINK-34806][postgres] Expose scan.newly-added-table.enabled option (#4436) by Mehmet Can Şakiroğlu · 4 weeks ago
  34. 7d56000 [FLINK-40552][runtime] Support asynchronous transform execution (#4526) by haruki · 4 weeks ago
  35. 2ae8f87 [FLINK-40741][cdc-connector][mysql] Fix newly added table recovery after region failover (#4557) by Hang Ruan · 4 weeks ago
  36. 3194adb [FLINK-39410][pipeline-connector][elasticsearch] The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x (#4368) by Pei Yu · 4 weeks ago
  37. 4007c73 [FLINK-39610] Mongo CDC supports specifying individual SSL context (#4393) by yuxiqian · 4 weeks ago
  38. 5c61d4c [FLINK-40732][mongodb] Release finished snapshot split metadata after entering the stream phase (#4553) by Spoorthi Basu · 5 weeks ago
  39. 29c7fbd [FLINK-39567][connect/paimon] Add BLOB fields support (#4391) by Kunni · 5 weeks ago
  40. 73a547f [FLINK-40148][common] Fix TableIdRouter producing wrong sink table for multi-digit source suffix (#4473) by Pei Yu · 5 weeks ago
  41. 284ee77 [minor][fluss] Bump Fluss version to 1.0.0 (#4554) by Leonard Xu · 5 weeks ago
  42. 03fbfbf [FLINK-39416] Fix link address errors in documents (#4373) by Pei Yu · 5 weeks ago
  43. b54be00 [hotfix][runtime/python] Fix Python signature parsing concurrency issue (#4552) by yuxiqian · 5 weeks ago
  44. e5c58ad [FLINK-40697][cdc-base] Release finished snapshot split metadata after entering the stream phase (#4550) by Spoorthi Basu · 5 weeks ago
  45. f183bbd [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split (#4534) by xucq07 · 5 weeks ago
  46. 7ecab6a [FLINK-40690][cdc-connect][fluss] Preserve nested row field positions (#4549) by Xiaobing Fang · 5 weeks ago
  47. a1ec262 [FLINK-40473] Fix yarn-application mode failing to locate flink-cdc-dist jar with Flink version suffix (#4514) by yueqingshu · 5 weeks ago
  48. 1195559 [hotfix][test][sqlserver] Shift test time values to avoid Debezium time-type conversion bug (#4548) by yuxiqian · 5 weeks ago
  49. 017de09 [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value (#4536) by Vishal · 5 weeks ago
  50. 67ba6b1 [hotfix][transform] Preserve table comments through transform (#4537) by yuxiqian · 5 weeks ago
  51. 93a4013 [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY (#4532) by yuxiqian · 5 weeks ago
  52. 7d44ba3 [hotfix][route] Revert strict route rule regex matching case sensitivity (#4545) by yuxiqian · 5 weeks ago
  53. a16a09e [hotfix] Fix pipeline e2e CI compilation failure (#4547) by yuxiqian · 5 weeks ago
  54. 43f36c9 [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events (#4531) by yuxiqian · 5 weeks ago
  55. 5979021 [tests][ci] Split pipeline e2e into stages to avoid CI timeout (#4546) by yuxiqian · 5 weeks ago
  56. 09d4674 [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase (#4418) by Spoorthi Basu · 5 weeks ago
  57. e9e77b2 [FLINK-40656][runtime] Reset schema coordinator state on checkpoint restore (#4541) by Xiaobing Fang · 5 weeks ago
  58. b11d6fd [FLINK-40572][runtime] Support dynamic AI model selection (#4525) by haruki · 6 weeks ago
  59. 9f23c03 [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. (#4498) by Hongshun Wang · 7 weeks ago
  60. fdb7652 [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding (#4520) by haruki · 7 weeks ago
  61. a932233 [FLINK-40512] Cache typeRegistry to reduce the busy work on inferring schema change event (#4519) by Hongshun Wang · 7 weeks ago
  62. f535d56 [FLINK-40416][runtime] Add built-in text AI functions (#4512) by haruki · 8 weeks ago
  63. b5927d0 [FLINK-40507][connect/paimon] Upgrade Paimon SDK to 2.0.0 by Pei Yu · 8 weeks ago
  64. 5d86d11 [FLINK-39722][pipeline-connector][fluss] Support Fluss CDC Yaml Source. (#4494) by Hongshun Wang · 8 weeks ago
  65. 306cb32 [FLINK-40453][postgres] Not load table schema when initializing record emitter (#4513) by naivedogger · 9 weeks ago
  66. 23fb108 [FLINK-40340][mysql] Fix schema change exception when parsing MySQL zerofill data types without unsigned keyword (#4500) by Jzjsnow · 9 weeks ago
  67. 4f239e7 [hotfix][runtime] Respect UDF precedence during type validation (#4505) by haruki · 9 weeks ago
  68. 4478405 [FLINK-40441][pipeline-connector][postgres] Fix HikariCP class conflict in Flink CDC Postgres connector (#4511) by Jzjsnow · 9 weeks ago
  69. 48944c6 [FLINK-40409][runtime] CDC YAML supports inline Python UDF definition (#4501) by yuxiqian · 9 weeks ago
  70. 4e3767a [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits (#4503) by haruki · 10 weeks ago
  71. 53fe0f9 [FLINK-40411][runtime] Introduce OpenAI-compatible model client (#4507) by haruki · 10 weeks ago
  72. cc384a0 [FLINK-40313][runtime] Support nested collection functions in Transforms (#4496) by haruki · 2 months ago
  73. e3f0caf [FLINK-39568][runtime] Introduce AI model client function API (#4504) by haruki · 2 months ago
  74. 91040de [FLINK-39824][flink-connector-debezium] Cache relational table filter results (#4422) by Ran Tao · 2 months ago
  75. fdacb41 [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform (#4492) by haruki · 2 months ago
  76. ff26ee2 [FLINK-40312] [runtime] Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform (#4495) by haruki · 3 months ago
  77. 55cccc9 [FLINK-40223][runtime] Support additional Flink SQL string functions in YAML Transform (#4488) by haruki · 3 months ago
  78. 78b4fef [FLINK-40337][runtime] Preserve operator precedence in generated Janino expressions (#4499) by haruki · 3 months ago
  79. d1ae9f1 [FLINK-40239][runtime] Support additional Flink SQL regular expression functions in YAML Transform (#4491) by haruki · 3 months ago
  80. 6e8ef16 [FLINK-40274][cdc-cli] Remove unsupported kubernetes-session from target option help message (#4493) by jj.lee · 3 months ago
  81. 308359e [FLINK-40007][connect/postgres] Fix snapshot fetch size conf does not take effect (#4453) by wudi · 3 months ago
  82. aa42119 [FLINK-39732][cdc-base] Introduce ObjectIdDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) (#4409) by Hongshun Wang · 3 months ago
  83. c45eb56 [hotfix][pipeline-connector/sqlserver] Align pipeline default value with SQL API by Leonard Xu · 3 months ago
  84. 61e0d2c [FLINK-40202][cdc-base] Init enumerator metrics before opening SnapshotSplitAssigner to avoid ConcurrentModificationException (#4480) by naivedogger · 3 months ago
  85. 85b83fc [FLINK-40151][runtime] Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation (#4474) by haruki · 3 months ago
  86. a52fe0d [FLINK-40159][connect/hudi] Support Hive sync for Hudi pipeline sink (#4476) by BreadS · 3 months ago
  87. 124bffe [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478) by haruki · 3 months ago
  88. be5399f [FLINK-38647][connect/postgres] Improve error message when REPLICA IDENTITY FULL is not configured (#4439) by BreadS · 3 months ago
  89. b18f95e [FLINK-39777][common] Add TableId partitioning strategy configuration (#4423) by haruki · 3 months ago
  90. cd8b8a9 [docs][connect/postgres] Improve Incremental Snapshot Reading formatting and references (#4472) by nhuantho · 3 months ago
  91. bdf32d7 [hotfix][ci] Exclude Flink compatibility modules from Javadocs generation (#4470) by yuxiqian · 3 months ago
  92. 36d2121 [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink (#4471) by haruki · 3 months ago
  93. 4371a4e [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner (#4469) by Purushottam Sinha · 3 months ago
  94. e780a7c [FLINK-39760][postgres] Fix missing JTS core dependency of PostgreSQL YAML connector (#4467) by haruki · 4 months ago
  95. 0e07178 [hotfix] Bump Mockito for JDK 17 tests (#4463) by yuxiqian · 4 months ago
  96. fd5b636 [FLINK-40091][connect/paimon] Upgrade Paimon SDK to 1.4.2 (#4465) by Pei Yu · 4 months ago
  97. db6178d [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions (#4380) by yuxiqian · 4 months ago
  98. e1e9c93 [FLINK-40043][paimon] Fix NoSuchElementException when restoring PaimonSink with increased parallelism. (#4457) by Pei Yu · 4 months ago
  99. 279278a [FLINK-39934][postgres] Fix invalid tables format error message (#4442) by Ran Tao · 4 months ago
  100. accee65 [test][pipeline-e2e] Share stream split readiness wait by Leonard Xu · 4 months ago