Google Git
Sign in
apache/flink-cdc/HEAD
  1. 885a059 [FLINK-39204][pipeline-connector/fluss] Fluss yaml sink support add column at last by Hongshun Wang · 27 hours ago master
  2. a3576d9 [FLINK-38726][fluss] Bump Fluss version to 0.9.0-incubating by Leonard Xu · 35 hours ago
  3. a19fdfe [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation (#4252) by Jia Fan · 2 days ago
  4. c05af15 [FLINK-38334][mysql] Fix MySQL CDC source stuck in INITIAL_ASSIGNING (#4278) by Sergei Morozov · 2 days ago
  5. a1cfab9 [FLINK-38833][paimon] Shuffle record to different subtasks by table, partition and bucket. (#4298) by Pei Yu · 3 days ago
  6. 31d68ac [chore][test] Fix flaky postgres pipeline test case (#4293) by Jia Fan · 4 days ago
  7. 69dae39 [FLINK-37485][starrocks] Add support for TIME type (#4253) by Jia Fan · 4 days ago
  8. c155638 [ci] Fix docker environment related test failure (#4275) by yuxiqian · 8 days ago
  9. ef9f977 [Minor][FLINK-39168][cdc-connector-mysql] Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: (#4288) by Thorne · 8 days ago
  10. 60344ed [FLINK-39071] Select fields rather * to read snapshot data in case schema changes. (#4273) by Hongshun Wang · 8 days ago
  11. c8e030f0 [pipeline] Use GHA workflow triggers to run labeler workflow (#4274) by yuxiqian · 9 days ago
  12. 39749bf [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors (#4247) by Thorne · 10 days ago
  13. d993c6a [FLINK-38455][elasticsearch][fix] Fix Elasticsearch Missing required property 'BulkRequest.operations' error (#4270) by Jia Fan · 10 days ago
  14. 2a23f71 [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier (#4282) by Thorne · 10 days ago
  15. e779015 [FLINK-39144][paimon] Fix ioManager close.(#4283) by Pei Yu · 11 days ago
  16. 1969f83 [test] Improve pipeline connector test coverage i.e. doris/postgres/fluss (#4266) by Leonard Xu · 11 days ago
  17. 8393a6a [FLINK-39066][pipeline-connector][Fluss] Fix the metric histogram always return null (#4281) by Thorne · 11 days ago
  18. 2f59f35 [FLINK-38601][connect/mongodb] Catch throwable errors when consuming from unbounded streams (#4213) by SkylerLin · 3 weeks ago
  19. 8e9474f [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` (#4272) by Kunni · 3 weeks ago
  20. ef5777a [FLINK-39063][connect/fluss] Fix some spelling mistakes in fluss pipeline connector (#4271) by Thorne · 3 weeks ago
  21. 7a83225 [FLINK-39056][pipeline-connector][iceberg] Fix Duplicate Data Issue in Iceberg Sink During Two-Phase Commit (#4269) by fcfangcc · 3 weeks ago
  22. c8e444b [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. (#3995) by linjianchang · 4 weeks ago
  23. 1c59744 [FLINK-38512][postgres] Update database name validation to allow hyphens (#4258) by Jia Fan · 4 weeks ago
  24. aac7d8d [FLINK-39048][iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 (#4265) by suhwan · 4 weeks ago
  25. 6e3e02d [FLINK-39047][docs] Translate Pipeline Transform documentations to Chinese (#4264) by Jia Fan · 4 weeks ago
  26. 376f795 [FLINK-39038][infra] Limit GitHub actions max parallelism and workflow triggers (#4263) by yuxiqian · 4 weeks ago
  27. 7b926ed [FLINK-38514][postgres] Add support for UUID array type in PostgreSQL CDC connector (#4255) by Jia Fan · 4 weeks ago
  28. 37b7c51 [FLINK-39010][transform] YAML Pipeline supports item subscription of Variant type (#4261) by Jia Fan · 4 weeks ago
  29. 97baee4 [ci] Fix master branch documentation build failure (#4260) by yuxiqian · 4 weeks ago
  30. 09ad789 [FLINK-38888][transform] YAML Pipeline supports item subscription of ARRAY, MAP, and ROW (#4241) by Jia Fan · 4 weeks ago
  31. e0c08f7 [hotfix][kafka] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) (#4240) by SkylerLin · 5 weeks ago
  32. ea30fd6 [chore][improve][fluss] Improve flaky test case FlussSinkITCase (#4256) by Jia Fan · 5 weeks ago
  33. 7f2fd1f [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity (#4250) by Jia Fan · 5 weeks ago
  34. 4271144 [FLINK-38906] Pass transform parser in context and polish built-in functions (#4248) by yuxiqian · 5 weeks ago
  35. 93e5547 [FLINK-38520][postgres] Postgres YAML CDC support array with null element (#4254) by Jia Fan · 5 weeks ago
  36. 3a2a3bf [FLINK-38965][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector (#4239) by Jia Fan · 5 weeks ago
  37. f78e5ee [FLINK-38985][docs] Add documentation for VARIANT type and PARSE_JSON functions (#4249) by suhwan · 5 weeks ago
  38. 1368626 [FLINK-38994][cli] Remove log4j1 dependency (#4242) by Mingliang Zhu · 5 weeks ago
  39. 798d068 [FLINK-38996][transform] Enhance error messages for projection and filtering expressions (#4243) by Jia Fan · 5 weeks ago
  40. 79683cf [FLINK-38836][docs] update section headings and improve pipeline configuration options (#4244) by Jia Fan · 5 weeks ago
  41. 7f627ff [FLINK-38887] Transform supports handling nested types (ARRAY, MAP, ROW, VARIANT) (#4236) by yuxiqian · 5 weeks ago
  42. 0cfe1d3 [FLINK-38889][pipeline][kafka] Support serializing complex types(MAP, ARRAY, ROW) to JSON (Debezium / Canal) (#4221) by SkylerLin · 5 weeks ago
  43. df6893d [minor][docs] add JDK baseline version and remove useless code (#4238) by Jia Fan · 6 weeks ago
  44. 7f909f4 [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector (#4170) by Tejansh · 6 weeks ago
  45. d26d2ce [hotfix] Upgrade labeler workflow config format to v6 (#4237) by Pei Yu · 6 weeks ago
  46. 3258f6e Upgrade GitHub Actions for Node 24 compatibility (#4235) by Pei Yu · 6 weeks ago
  47. b9da3e4 [minor] Fix incorrect log when malformed scan.startup.mode (#4234) by Mukhutdinov Artur · 6 weeks ago
  48. 8421122 [FLINK-38886] Introduce `GenericRecordData` and Internal / External converters in flink-cdc-common (#4218) by yuxiqian · 6 weeks ago
  49. a80edd1 [FLINK-38925][docs] Update Matomo URL to the right domain (#4230) by Martijn Visser · 6 weeks ago
  50. 7d9e1c6 [FLINK-38879][pipeline-connector][paimon] Add support for creating and writing table with variant type. (#4228) by Kunni · 7 weeks ago
  51. dd6fa19 [FLINK-38878][runtime] Add parse_json function. (#4227) by Kunni · 7 weeks ago
  52. 538b8fa [FLINK-38779] Route module supports standard RegExp replacement rules (#4190) by yuxiqian · 7 weeks ago
  53. f5cec12 [FLINK-38877][common] Add variant type. (#4217) by Kunni · 7 weeks ago
  54. 1899bc1 [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink (#4192) by fcfangcc · 8 weeks ago
  55. 30be698 [tests][runtime] Add spec-based transform test cases by yuxiqian · 8 weeks ago
  56. 6547c32 [build] Update copyright year to 2026 by Leonard Xu · 8 weeks ago
  57. 1796eb6 [FLINK-38596][pipeline-connector][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent (#4215) by SkylerLin · 8 weeks ago
  58. a40b870 [FLINK-38838] Update spotless style version to AOSP 1.24.0 by yuxiqian · 9 weeks ago
  59. 35df790 [ci] Combine test modules together to reduce test matrix size by yuxiqian · 9 weeks ago
  60. 91a7af1 [FLINK-38100][pipeline-connector][iceberg] Bump Iceberg dependency to 1.10.1 in iceberg-pipeline-sink connector (#4145) by Luca Occhipinti · 8 weeks ago
  61. 99c00f3 [FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID (#4209) by ouyangwulin · 9 weeks ago
  62. 42580dc [FLINK-37676][common] Add caching mechanism to Table ID Selectors for better performance (#3994) by Tianzhu Wen · 9 weeks ago
  63. 533072b [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204) by wudi · 9 weeks ago
  64. 44fb79f [hotfix] Fix build_docs GHA workflow not working after Java 11 upgrade (#4201) by yuxiqian · 10 weeks ago
  65. db1caee [FLINK-38837][docs][pipeline-connector/hudi] Add documentation for Hudi connector and improve the configuration by Shuo Cheng · 2 months ago
  66. 1da0567 [FLINK-38730][build] Bump default JDK version from 8 to 11 and support optional JDK17 by Kunni · 2 months ago
  67. 097aa9a [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector (#4198) by Mingliang Zhu · 2 months ago
  68. c3f6657 [FLINK-38818][pipeline-connector][posgtresql]Build createTableEventCache using TableSchemas from split (#4194) by ouyangwulin · 2 months ago
  69. 9ff568e [FLINK-36313][pipeline-connector/hudi] Introduce Pipeline Sink Connector for Apache Hudi by voonhous · 2 months ago
  70. 2293651 [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector (#4197) by Mingliang Zhu · 2 months ago
  71. e2b8076 [FLINK-38813][mysql] Support for emitting heartbeat events (#4193) by Tejansh · 2 months ago
  72. f520424 [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191) by yuxiqian · 3 months ago
  73. 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 · 3 months ago
  74. 2354f05 [FLINK-38784][pipeline-connector][paimon] Bump Paimon version to 1.3.1 (#4189) by Pei Yu · 3 months ago
  75. 001cba0 [FLINK-38737][common] Fix potential backwards incompatibility with fallback keys (#4185) by Kunni · 3 months ago
  76. 94e0c55 [hotfix] Bump Doris flink connector version to 25.1.0 (#4188) by yuxiqian · 3 months ago
  77. 8edc345 [FLINK-35633] Add more YAML structure validations & provide better error messages (#4172) by yuxiqian · 3 months ago
  78. 4b44b2f update markdown lint check (#4184) by Kevin Liu · 3 months ago
  79. 7ad789e [FLINK-38723][common/composer] Add getFlinkConf method to Context. (#4179) by Kunni · 3 months ago
  80. 25fa95e [FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171) by Junbo Wang · 4 months ago
  81. 55aff6e [FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174) by Tejansh · 4 months ago
  82. 4bab367 [FLINK-38618][base] Fix offset error due to duplicated stream split during TM failover if startup mode is latest-offset by Xin Gong · 4 months ago
  83. cfaf3cb [FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism (#4150) by fcfangcc · 4 months ago
  84. 6767d85 [FLINK-38279][mysql] Add SnapshotPendingSplitsState to MySQL checkpoint state during restoration by Dustin Washington · 4 months ago
  85. 7a6bfd8 [FLINK-38568] [mysql-cdc] [cdc-base] Optimize binlog split lookup using binary search by big face cat · 4 months ago
  86. 27dee1f [FLINK-38680][build] Bump Flink 1.19 and 1.20 patch versions by big face cat · 4 months ago
  87. 6542026 [FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while reporting metrics of Iceberg committer. (#4168) by fcfangcc · 4 months ago
  88. 6a18cd7 [FLINK-38478][pipeline-connector][paimon] Generate a random commit user and store it in state. (#4149) by Kunni · 4 months ago
  89. 920fab9 [FLINK-38593][test][sqlserver] Fix unstable sqlserver e2e tests via adding more time to wait SqlserverAgent Ready by Leonard Xu · 4 months ago
  90. 4698b7a [FLINK-38550][connect/mongodb] Allow recovery from more change stream expiration scenarios (#4161) by Sachin Mittal · 4 months ago
  91. c819525 [FLINK-34735][docs] Translate "Developer Guide - Understanding Flink CDC API" Page to Chinese by Edward Zhuang · 4 months ago
  92. a62bae7 [FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission (#4158) by Junbo Wang · 5 months ago
  93. 57726d2 [FLINK-38540] Fix unintended object reuse in `TransformExpressionKey` (#4157) by yuxiqian · 5 months ago
  94. 7c7a74d [FLINK-38496][docs] Icerberg YAML sink requires extra Hadoop jar to run (#4153) by Hongshun Wang · 5 months ago
  95. e0e0931 [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly (#3892) by big face cat · 5 months ago
  96. 2850603 [hotfix][docs] Update overview pages for connector version by Leonard Xu · 5 months ago
  97. a41423e [FLINK-36631][source-connector][oracle] Add oracle read data by specific offset (#3675) by wudi · 5 months ago
  98. 3559220 [FLINK-38452] Fix unable to read incremental data from MongoDB collections with dots (`.`) (#4148) by yuxiqian · 5 months ago
  99. c7891ed [hotfix][ci] Run MongoDB tests with supported 7.0.x and 8.0.x images (#4147) by yuxiqian · 5 months ago
  100. 682d791 [FLINK-38440][pipeline-connector][iceberg] fixed the problem of writing SMALLINT/TINYINT data to Iceberg. (#4146) by fcfangcc · 5 months ago