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