Google Git
Sign in
apache/flink-cdc/HEAD
  1. b94d7b2 [FLINK-39563][paimon] Upgrade paimon dependency to 1.4.1 (#4384) by Pei Yu · 20 hours ago master
  2. fe79b4d [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image (#4111) by yuanoOo · 23 hours ago
  3. eb3cdc0 [FLINK-38061][mysql] Make defensive copies of collections in SnapshotPendingSplitsState to prevent concurrent modification issues (#4379) by Jia Fan · 9 days ago
  4. 13cd198 [FLINK-39363][test] Fix flaky test PaimonSinkITCase (#4366) by Jia Fan · 3 weeks ago
  5. b48d8eb Add flink-cdc-flink*-compat to output t jar for source connector. (#4361) by Pei Yu · 3 weeks ago
  6. 1a1e81c [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties (#4351) by EricZeng · 4 weeks ago
  7. 23e23d6 [FLINK-39372][connect/mysql] Fix comparison logic for binlog filename with various digits (#4358) by yuxiqian · 4 weeks ago
  8. 209c0c6 [FLINK-39362][Docs] Fix broken/outdated connector download links and improve link maintenance strategy (#4356) by Kunni · 4 weeks ago
  9. ec244f1 [FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type (#4295) by Mingliang Zhu · 4 weeks ago
  10. 11a6ba7 [FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end (#4296) by Chengbing Liu · 4 weeks ago
  11. 1a65ad0 [ci] Fix constant nightly CI pipeline failure (#4354) by yuxiqian · 4 weeks ago
  12. 73305fb [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations (#4350) by yuxiqian · 4 weeks ago
  13. 25a5817 [FLINK-38248] The microseconds default value of '0000-00-00 00:00:00.000000' for MySQL TIMESTAMP fields is not supported in downstream systems. (#4251) by Patrick · 4 weeks ago
  14. 68ee0c9 [FLINK-39346] Improve error message of invalid AddColumnEvents (#4353) by Pei Yu · 4 weeks ago
  15. 380da4a [FLINK-39344][doc] Fix inconsistencies in MySQL Pipeline Connector documentation (#4352) by yueqingshu · 5 weeks ago
  16. 9128a6b [Kafka] Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. (#4347) by Pei Yu · 5 weeks ago
  17. 6741c1d Clean up the compatibility code for Flink 1.19 in the e2e-tests module. (#4348) by Pei Yu · 5 weeks ago
  18. e4cf027 [FLINK-39329][MySQL] Improve error message for tables without primary key in incremental snapshot (#4342) by EricZeng · 5 weeks ago
  19. c408149 Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. (#4346) by Pei Yu · 5 weeks ago
  20. ccb5d4c [docs] Polish README.md (#4349) by yuxiqian · 5 weeks ago
  21. b569d64 FLINK-39288 [docs] Update pipeline connectors overview with Flink version specific jar names (#4345) by Kunni · 5 weeks ago
  22. a1b7d1e [FLINK-39300][connect/mysql] Reuse ObjectMapper as static constant to avoid repeated instantiation (#4330) by EricZ · 5 weeks ago
  23. b169f78 [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. (#4337) by Hongshun Wang · 5 weeks ago
  24. 619ab90 [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x (#4339) by Kunni · 5 weeks ago
  25. 48f8bf9 [docs] Reorder Flink CDC version mapping tables in descending order (#4340) by Leonard Xu · 5 weeks ago
  26. 133cc8e [doc][build] Update version to 3.7-SNAPSHOT by Kunni · 5 weeks ago
  27. b58561a [hotfix] [pipeline-connector/postgres] Fix wrong SchemaChangeEnabled option during delivery by Hongshun Wang · 5 weeks ago
  28. 1f64e57 [FLINK-39171][oracle-cdc] Fix Oracle pipeline connector wrong field case (#4292) by Jia Fan · 5 weeks ago
  29. 89d6f93 [release] Improve version handling in deploy_staging_jars.sh (#4335) by Kunni · 5 weeks ago
  30. 08f3fb8 [FLINK-39289][paimon] Supports executing TRUNCATE schema change events on tables with deletion-vectors.enabled:true set (#4327) by zexin.gong · 5 weeks ago
  31. 723615b [FLINK-39312][pipeline][hudi] Fix Hudi connector packaging to include flink-metrics-dropwizard dependency. (#4332) by Shuo Cheng · 5 weeks ago
  32. 283edb6 [FLINK-39297][doc] Update pipeline connectors overview for Flink CDC 3.6.0 (#4329) by Kunni · 5 weeks ago
  33. 3d405fb [FLINK-39295] Update MySQL docs to reflect MySQL 8.4+ support (#4331) by yuxiqian · 5 weeks ago
  34. 8e576aa [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. (#4316) by Hongshun Wang · 6 weeks ago
  35. 5d8a317 [FLINK-37203] Alter table comment or column comment (#3893) by moses · 6 weeks ago
  36. a46b7f4 [FLINK-38839][runtime] Support semicolon delimiter for table-options (#4199) by Lanny Boarts · 6 weeks ago
  37. 987c466 [FLINK-39245][Iceberg] Add AWS Glue Catalog support for Iceberg pipeline connector (#4314) by HUANG XIAO · 6 weeks ago
  38. e663b00 [build] Add update_version.sh to help build connector jars with FLINK_VERSION suffix version. (#4325) by Kunni · 6 weeks ago
  39. aabf306 [FLINK-36520] MySQL CDC Supports connecting to MySQL server 8.4+ (#3666) by yuxiqian · 6 weeks ago
  40. a75e580 [hotfix] Fix compile error (#4326) by Kunni · 6 weeks ago
  41. c42e40d [FLINK-38139] Fix consecutive online schema change causes job failure (#4324) by Junbo Wang · 6 weeks ago
  42. 8bae0e5 [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission (#4087) by Sergei Morozov · 6 weeks ago
  43. 8d5be44 [FLINK-37837][core] Always add create.table to include.schema.changes option (#4262) by Jia Fan · 6 weeks ago
  44. 9ff51f6 [FLINK-38729] Add Flink2 support for Source/Pipeline connector. (#4322) by Kunni · 6 weeks ago
  45. 78d6adf [FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader (#4311) by chengcongchina · 6 weeks ago
  46. c4b698b [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges (#4286) by Jia Fan · 6 weeks ago
  47. 619903c [FLINK-39209][doris] Fix time data type serialiazation when sink to doris with pipeline connector (#4312) by chengcongchina · 6 weeks ago
  48. 2acf693 [FLINK-39230] Transform should convert partially filtered UPDATE events to INSERT / DELETE (#4319) by yuxiqian · 6 weeks ago
  49. c9ffab7 [FLINK-38831][runtime] Route configuration support FIRST_MATCH mode (#4212) by SkylerLin · 6 weeks ago
  50. bcb4a4b [FLINK-39257] Remove compatibility code for older versions of Flink (#4317) by Pei Yu · 6 weeks ago
  51. 5e21883 [FLINK-39232] Loosen transformed schema merging validation check (#4315) by yuxiqian · 6 weeks ago
  52. 323b2bc [FLINK-38729] Add support for Flink 2.2.0 (#4294) by Kunni · 7 weeks ago
  53. db595e4 [hotfix] Fix spotless check failure (#4313) by Kunni · 7 weeks ago
  54. 368a807 [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test (#4309) by Mingliang Zhu · 7 weeks ago
  55. 3580bf4 [FLINK-38844][pipeline-connector][postgres]Add metadata column support (#4202) by Lanny Boarts · 7 weeks ago
  56. 363095e [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive (#4284) by Pei Yu · 7 weeks ago
  57. 91ae677 [FLINK-39055][Iceberg] Support default column values in Iceberg sink connector (#4277) by suhwan · 7 weeks ago
  58. 570faa7 [FLINK-38247][MySQL] Handle BIGINT UNSIGNED overflow correctly in PreparedStatement. (#4117) by suhwan · 7 weeks ago
  59. 3778300 [minor][docs][style] Update documentation link and improve code style (#3961) by chenhongyu · 7 weeks ago
  60. 0ae9abd [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist (#4024) by Wink · 7 weeks ago
  61. 88b1203 [DOC][MINOR] Update starrocks.md (#4304) by Mingliang Zhu · 7 weeks ago
  62. dc5e923 [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector (#4303) by Jia Fan · 7 weeks ago
  63. c003b93 [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and should have a private instance (#4306) by Thorne · 7 weeks ago
  64. 885a059 [FLINK-39204][pipeline-connector/fluss] Fluss yaml sink support add column at last by Hongshun Wang · 8 weeks ago
  65. a3576d9 [FLINK-38726][fluss] Bump Fluss version to 0.9.0-incubating by Leonard Xu · 8 weeks ago
  66. a19fdfe [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation (#4252) by Jia Fan · 8 weeks ago
  67. c05af15 [FLINK-38334][mysql] Fix MySQL CDC source stuck in INITIAL_ASSIGNING (#4278) by Sergei Morozov · 8 weeks ago
  68. a1cfab9 [FLINK-38833][paimon] Shuffle record to different subtasks by table, partition and bucket. (#4298) by Pei Yu · 8 weeks ago
  69. 31d68ac [chore][test] Fix flaky postgres pipeline test case (#4293) by Jia Fan · 8 weeks ago
  70. 69dae39 [FLINK-37485][starrocks] Add support for TIME type (#4253) by Jia Fan · 8 weeks ago
  71. c155638 [ci] Fix docker environment related test failure (#4275) by yuxiqian · 9 weeks ago
  72. 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 · 9 weeks ago
  73. 60344ed [FLINK-39071] Select fields rather * to read snapshot data in case schema changes. (#4273) by Hongshun Wang · 9 weeks ago
  74. c8e030f0 [pipeline] Use GHA workflow triggers to run labeler workflow (#4274) by yuxiqian · 9 weeks ago
  75. 39749bf [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors (#4247) by Thorne · 9 weeks ago
  76. d993c6a [FLINK-38455][elasticsearch][fix] Fix Elasticsearch Missing required property 'BulkRequest.operations' error (#4270) by Jia Fan · 9 weeks ago
  77. 2a23f71 [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier (#4282) by Thorne · 9 weeks ago
  78. e779015 [FLINK-39144][paimon] Fix ioManager close.(#4283) by Pei Yu · 9 weeks ago
  79. 1969f83 [test] Improve pipeline connector test coverage i.e. doris/postgres/fluss (#4266) by Leonard Xu · 9 weeks ago
  80. 8393a6a [FLINK-39066][pipeline-connector][Fluss] Fix the metric histogram always return null (#4281) by Thorne · 9 weeks ago
  81. 2f59f35 [FLINK-38601][connect/mongodb] Catch throwable errors when consuming from unbounded streams (#4213) by SkylerLin · 3 months ago
  82. 8e9474f [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` (#4272) by Kunni · 3 months ago
  83. ef5777a [FLINK-39063][connect/fluss] Fix some spelling mistakes in fluss pipeline connector (#4271) by Thorne · 3 months ago
  84. 7a83225 [FLINK-39056][pipeline-connector][iceberg] Fix Duplicate Data Issue in Iceberg Sink During Two-Phase Commit (#4269) by fcfangcc · 3 months ago
  85. c8e444b [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. (#3995) by linjianchang · 3 months ago
  86. 1c59744 [FLINK-38512][postgres] Update database name validation to allow hyphens (#4258) by Jia Fan · 3 months ago
  87. aac7d8d [FLINK-39048][iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 (#4265) by suhwan · 3 months ago
  88. 6e3e02d [FLINK-39047][docs] Translate Pipeline Transform documentations to Chinese (#4264) by Jia Fan · 3 months ago
  89. 376f795 [FLINK-39038][infra] Limit GitHub actions max parallelism and workflow triggers (#4263) by yuxiqian · 3 months ago
  90. 7b926ed [FLINK-38514][postgres] Add support for UUID array type in PostgreSQL CDC connector (#4255) by Jia Fan · 3 months ago
  91. 37b7c51 [FLINK-39010][transform] YAML Pipeline supports item subscription of Variant type (#4261) by Jia Fan · 3 months ago
  92. 97baee4 [ci] Fix master branch documentation build failure (#4260) by yuxiqian · 3 months ago
  93. 09ad789 [FLINK-38888][transform] YAML Pipeline supports item subscription of ARRAY, MAP, and ROW (#4241) by Jia Fan · 3 months ago
  94. e0c08f7 [hotfix][kafka] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) (#4240) by SkylerLin · 3 months ago
  95. ea30fd6 [chore][improve][fluss] Improve flaky test case FlussSinkITCase (#4256) by Jia Fan · 3 months ago
  96. 7f2fd1f [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity (#4250) by Jia Fan · 3 months ago
  97. 4271144 [FLINK-38906] Pass transform parser in context and polish built-in functions (#4248) by yuxiqian · 3 months ago
  98. 93e5547 [FLINK-38520][postgres] Postgres YAML CDC support array with null element (#4254) by Jia Fan · 3 months ago
  99. 3a2a3bf [FLINK-38965][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector (#4239) by Jia Fan · 3 months ago
  100. f78e5ee [FLINK-38985][docs] Add documentation for VARIANT type and PARSE_JSON functions (#4249) by suhwan · 3 months ago