Google Git
Sign in
apache / flink-cdc / HEAD
  1. 7b926ed [FLINK-38514][postgres] Add support for UUID array type in PostgreSQL CDC connector (#4255) by Jia Fan · 5 hours ago master
  2. 37b7c51 [FLINK-39010][transform] YAML Pipeline supports item subscription of Variant type (#4261) by Jia Fan · 10 hours ago
  3. 97baee4 [ci] Fix master branch documentation build failure (#4260) by yuxiqian · 30 hours ago
  4. 09ad789 [FLINK-38888][transform] YAML Pipeline supports item subscription of ARRAY, MAP, and ROW (#4241) by Jia Fan · 3 days ago
  5. e0c08f7 [hotfix][kafka] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) (#4240) by SkylerLin · 3 days ago
  6. ea30fd6 [chore][improve][fluss] Improve flaky test case FlussSinkITCase (#4256) by Jia Fan · 3 days ago
  7. 7f2fd1f [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity (#4250) by Jia Fan · 3 days ago
  8. 4271144 [FLINK-38906] Pass transform parser in context and polish built-in functions (#4248) by yuxiqian · 4 days ago
  9. 93e5547 [FLINK-38520][postgres] Postgres YAML CDC support array with null element (#4254) by Jia Fan · 4 days ago
  10. 3a2a3bf [FLINK-38965][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector (#4239) by Jia Fan · 6 days ago
  11. f78e5ee [FLINK-38985][docs] Add documentation for VARIANT type and PARSE_JSON functions (#4249) by suhwan · 7 days ago
  12. 1368626 [FLINK-38994][cli] Remove log4j1 dependency (#4242) by Mingliang Zhu · 7 days ago
  13. 798d068 [FLINK-38996][transform] Enhance error messages for projection and filtering expressions (#4243) by Jia Fan · 7 days ago
  14. 79683cf [FLINK-38836][docs] update section headings and improve pipeline configuration options (#4244) by Jia Fan · 7 days ago
  15. 7f627ff [FLINK-38887] Transform supports handling nested types (ARRAY, MAP, ROW, VARIANT) (#4236) by yuxiqian · 7 days ago
  16. 0cfe1d3 [FLINK-38889][pipeline][kafka] Support serializing complex types(MAP, ARRAY, ROW) to JSON (Debezium / Canal) (#4221) by SkylerLin · 9 days ago
  17. df6893d [minor][docs] add JDK baseline version and remove useless code (#4238) by Jia Fan · 10 days ago
  18. 7f909f4 [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector (#4170) by Tejansh · 10 days ago
  19. d26d2ce [hotfix] Upgrade labeler workflow config format to v6 (#4237) by Pei Yu · 11 days ago
  20. 3258f6e Upgrade GitHub Actions for Node 24 compatibility (#4235) by Pei Yu · 11 days ago
  21. b9da3e4 [minor] Fix incorrect log when malformed scan.startup.mode (#4234) by Mukhutdinov Artur · 11 days ago
  22. 8421122 [FLINK-38886] Introduce `GenericRecordData` and Internal / External converters in flink-cdc-common (#4218) by yuxiqian · 2 weeks ago
  23. a80edd1 [FLINK-38925][docs] Update Matomo URL to the right domain (#4230) by Martijn Visser · 2 weeks ago
  24. 7d9e1c6 [FLINK-38879][pipeline-connector][paimon] Add support for creating and writing table with variant type. (#4228) by Kunni · 2 weeks ago
  25. dd6fa19 [FLINK-38878][runtime] Add parse_json function. (#4227) by Kunni · 3 weeks ago
  26. 538b8fa [FLINK-38779] Route module supports standard RegExp replacement rules (#4190) by yuxiqian · 3 weeks ago
  27. f5cec12 [FLINK-38877][common] Add variant type. (#4217) by Kunni · 3 weeks ago
  28. 1899bc1 [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink (#4192) by fcfangcc · 3 weeks ago
  29. 30be698 [tests][runtime] Add spec-based transform test cases by yuxiqian · 3 weeks ago
  30. 6547c32 [build] Update copyright year to 2026 by Leonard Xu · 4 weeks ago
  31. 1796eb6 [FLINK-38596][pipeline-connector][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent (#4215) by SkylerLin · 4 weeks ago
  32. a40b870 [FLINK-38838] Update spotless style version to AOSP 1.24.0 by yuxiqian · 5 weeks ago
  33. 35df790 [ci] Combine test modules together to reduce test matrix size by yuxiqian · 5 weeks ago
  34. 91a7af1 [FLINK-38100][pipeline-connector][iceberg] Bump Iceberg dependency to 1.10.1 in iceberg-pipeline-sink connector (#4145) by Luca Occhipinti · 4 weeks ago
  35. 99c00f3 [FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID (#4209) by ouyangwulin · 4 weeks ago
  36. 42580dc [FLINK-37676][common] Add caching mechanism to Table ID Selectors for better performance (#3994) by Tianzhu Wen · 5 weeks ago
  37. 533072b [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204) by wudi · 5 weeks ago
  38. 44fb79f [hotfix] Fix build_docs GHA workflow not working after Java 11 upgrade (#4201) by yuxiqian · 6 weeks ago
  39. db1caee [FLINK-38837][docs][pipeline-connector/hudi] Add documentation for Hudi connector and improve the configuration by Shuo Cheng · 6 weeks ago
  40. 1da0567 [FLINK-38730][build] Bump default JDK version from 8 to 11 and support optional JDK17 by Kunni · 6 weeks ago
  41. 097aa9a [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector (#4198) by Mingliang Zhu · 6 weeks ago
  42. c3f6657 [FLINK-38818][pipeline-connector][posgtresql]Build createTableEventCache using TableSchemas from split (#4194) by ouyangwulin · 6 weeks ago
  43. 9ff568e [FLINK-36313][pipeline-connector/hudi] Introduce Pipeline Sink Connector for Apache Hudi by voonhous · 6 weeks ago
  44. 2293651 [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector (#4197) by Mingliang Zhu · 6 weeks ago
  45. e2b8076 [FLINK-38813][mysql] Support for emitting heartbeat events (#4193) by Tejansh · 6 weeks ago
  46. f520424 [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191) by yuxiqian · 7 weeks ago
  47. c1a7d0b [FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. (#4165) by 5herhom · 8 weeks ago
  48. 2354f05 [FLINK-38784][pipeline-connector][paimon] Bump Paimon version to 1.3.1 (#4189) by Pei Yu · 8 weeks ago
  49. 001cba0 [FLINK-38737][common] Fix potential backwards incompatibility with fallback keys (#4185) by Kunni · 9 weeks ago
  50. 94e0c55 [hotfix] Bump Doris flink connector version to 25.1.0 (#4188) by yuxiqian · 9 weeks ago
  51. 8edc345 [FLINK-35633] Add more YAML structure validations & provide better error messages (#4172) by yuxiqian · 9 weeks ago
  52. 4b44b2f update markdown lint check (#4184) by Kevin Liu · 9 weeks ago
  53. 7ad789e [FLINK-38723][common/composer] Add getFlinkConf method to Context. (#4179) by Kunni · 2 months ago
  54. 25fa95e [FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171) by Junbo Wang · 3 months ago
  55. 55aff6e [FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174) by Tejansh · 3 months ago
  56. 4bab367 [FLINK-38618][base] Fix offset error due to duplicated stream split during TM failover if startup mode is latest-offset by Xin Gong · 3 months ago
  57. cfaf3cb [FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism (#4150) by fcfangcc · 3 months ago
  58. 6767d85 [FLINK-38279][mysql] Add SnapshotPendingSplitsState to MySQL checkpoint state during restoration by Dustin Washington · 3 months ago
  59. 7a6bfd8 [FLINK-38568] [mysql-cdc] [cdc-base] Optimize binlog split lookup using binary search by big face cat · 3 months ago
  60. 27dee1f [FLINK-38680][build] Bump Flink 1.19 and 1.20 patch versions by big face cat · 3 months ago
  61. 6542026 [FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while reporting metrics of Iceberg committer. (#4168) by fcfangcc · 3 months ago
  62. 6a18cd7 [FLINK-38478][pipeline-connector][paimon] Generate a random commit user and store it in state. (#4149) by Kunni · 3 months ago
  63. 920fab9 [FLINK-38593][test][sqlserver] Fix unstable sqlserver e2e tests via adding more time to wait SqlserverAgent Ready by Leonard Xu · 3 months ago
  64. 4698b7a [FLINK-38550][connect/mongodb] Allow recovery from more change stream expiration scenarios (#4161) by Sachin Mittal · 3 months ago
  65. c819525 [FLINK-34735][docs] Translate "Developer Guide - Understanding Flink CDC API" Page to Chinese by Edward Zhuang · 3 months ago
  66. a62bae7 [FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission (#4158) by Junbo Wang · 4 months ago
  67. 57726d2 [FLINK-38540] Fix unintended object reuse in `TransformExpressionKey` (#4157) by yuxiqian · 4 months ago
  68. 7c7a74d [FLINK-38496][docs] Icerberg YAML sink requires extra Hadoop jar to run (#4153) by Hongshun Wang · 4 months ago
  69. e0e0931 [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly (#3892) by big face cat · 4 months ago
  70. 2850603 [hotfix][docs] Update overview pages for connector version by Leonard Xu · 4 months ago
  71. a41423e [FLINK-36631][source-connector][oracle] Add oracle read data by specific offset (#3675) by wudi · 4 months ago
  72. 3559220 [FLINK-38452] Fix unable to read incremental data from MongoDB collections with dots (`.`) (#4148) by yuxiqian · 4 months ago
  73. c7891ed [hotfix][ci] Run MongoDB tests with supported 7.0.x and 8.0.x images (#4147) by yuxiqian · 4 months ago
  74. 682d791 [FLINK-38440][pipeline-connector][iceberg] fixed the problem of writing SMALLINT/TINYINT data to Iceberg. (#4146) by fcfangcc · 4 months ago
  75. 2fa6089 [FLINK-38232] [docs] Update the connector documentation to reflect the new features in Flink CDC 3.5.0 (#4102) by suhwan · 4 months ago
  76. 6db99a6 [minor][hotfix][docs] Fluss use STRING rather than VARCHAR. (#4144) by Hongshun Wang · 4 months ago
  77. ab70a29 [minor][hotfix][docs] Fix some error in postgres yaml document. (#4140) by Hongshun Wang · 5 months ago
  78. 83ef3de [FLINK-37199][doc] Update configuration in quickstart. (#3880) by Kunni · 5 months ago
  79. 3fb72cc [build] Automate property replacement in pom.xml and exclude the release directory from license checks. (#4134) by Kunni · 5 months ago
  80. 7bbfab0 [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect (#4133) by ouyangwulin · 5 months ago
  81. c6f5481 [FLINK-38398[pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config(#4129) by ouyangwulin · 5 months ago
  82. ae26861 [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules (#4126) by yuxiqian · 5 months ago
  83. 39935a7 [build] Update version to 3.6-SNAPSHOT. (#4125) by Kunni · 5 months ago
  84. 99427e8 [Flink-38277] [postgres] Drop slot when startup.mode=snapshot and skip backfill.(#4113) by ouyangwulin · 5 months ago
  85. d576618 [minor] Fix potential sql connection statement issue. (#4123) by Kunni · 5 months ago
  86. 85a79aa [FLINK-37065]: Fix the problem that MySQL cdc may lose/skip data during recovering from the checkpoint (#3845) by Ihor Mielientiev · 5 months ago
  87. 6b6eb80 [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. (#3590) by Kunni · 5 months ago
  88. 26d987a [minor] Update flink-cdc.sh to handle all .jar files even inside subdirectories (#4071) by Мухутдинов Артур · 5 months ago
  89. cabfd30 [minor][pipeline-connector][maxcompute][e2e] Remove repeated dependency of maxcompute, and change the phase of "download-flink-release" to test in pipeline-e2e-test. (#3991) by Tianzhu Wen · 5 months ago
  90. b9437bf [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. (#4119) by Kunni · 5 months ago
  91. 32ec9f5 [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. (#4120) by Kunni · 5 months ago
  92. f22b214 [hotfix][postgres] PostgresSourceFetchTaskContext log do not output PostgresConnectorConfig (#3855) by hql0312 · 5 months ago
  93. 2712b49 [FLINK-37979][minor][mysql] Remove obsolete MySQL CDC snapshot split assigner code (#4048) by Sergei Morozov · 5 months ago
  94. c6a0b6e [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. (#4101) by Hongshun Wang · 5 months ago
  95. 6052bde [FLINK-36980][docs] Add "Streaming ELT from MySQL to Kafka" quick-start guide (#4033) by kangzai · 5 months ago
  96. 67a5ca1 [FLINK-37479][postgres] Add support for PARTITIONED TABLE (#4004) by Vinh Pham · 5 months ago
  97. ea384c8 [FLINK-38310] Fix handling equals and hashcode method of binary boundaries in FinishedSnapshotSplitInfo (#4112) by Sergei Morozov · 5 months ago
  98. bd24799 [FLINK-37096][cdc-connector][mongodb] Update the value of emitDelay & fetchDelay from 20098d to -1ms in the snapshot reading phase. (#4034) by kangzai · 5 months ago
  99. cb2c71a [hotfix][docs] Fixed typo on Parameter name for Oracle CDC Adapter (#4116) by Naci Simsek · 5 months ago
  100. 70cc342 [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. (#4081) by Kunni · 5 months ago