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