Google Git
Sign in
apache/flink-cdc/HEAD
  1. c45eb56 [hotfix][pipeline-connector/sqlserver] Align pipeline default value with SQL API by Leonard Xu · 5 days ago master
  2. 61e0d2c [FLINK-40202][cdc-base] Init enumerator metrics before opening SnapshotSplitAssigner to avoid ConcurrentModificationException (#4480) by naivedogger · 6 days ago
  3. 85b83fc [FLINK-40151][runtime] Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation (#4474) by haruki · 6 days ago
  4. a52fe0d [FLINK-40159][connect/hudi] Support Hive sync for Hudi pipeline sink (#4476) by BreadS · 7 days ago
  5. 124bffe [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478) by haruki · 9 days ago
  6. be5399f [FLINK-38647][connect/postgres] Improve error message when REPLICA IDENTITY FULL is not configured (#4439) by BreadS · 13 days ago
  7. b18f95e [FLINK-39777][common] Add TableId partitioning strategy configuration (#4423) by haruki · 2 weeks ago
  8. cd8b8a9 [docs][connect/postgres] Improve Incremental Snapshot Reading formatting and references (#4472) by nhuantho · 2 weeks ago
  9. bdf32d7 [hotfix][ci] Exclude Flink compatibility modules from Javadocs generation (#4470) by yuxiqian · 2 weeks ago
  10. 36d2121 [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink (#4471) by haruki · 2 weeks ago
  11. 4371a4e [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner (#4469) by Purushottam Sinha · 2 weeks ago
  12. e780a7c [FLINK-39760][postgres] Fix missing JTS core dependency of PostgreSQL YAML connector (#4467) by haruki · 3 weeks ago
  13. 0e07178 [hotfix] Bump Mockito for JDK 17 tests (#4463) by yuxiqian · 3 weeks ago
  14. fd5b636 [FLINK-40091][connect/paimon] Upgrade Paimon SDK to 1.4.2 (#4465) by Pei Yu · 3 weeks ago
  15. db6178d [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions (#4380) by yuxiqian · 3 weeks ago
  16. e1e9c93 [FLINK-40043][paimon] Fix NoSuchElementException when restoring PaimonSink with increased parallelism. (#4457) by Pei Yu · 3 weeks ago
  17. 279278a [FLINK-39934][postgres] Fix invalid tables format error message (#4442) by Ran Tao · 3 weeks ago
  18. accee65 [test][pipeline-e2e] Share stream split readiness wait by Leonard Xu · 3 weeks ago
  19. c32c651 [test][pipeline-e2e] Skip checkpointing non-streaming Iceberg job by Leonard Xu · 4 weeks ago
  20. 1357fe1 [test] Keep stabilization changes semantically strict by Leonard Xu · 4 weeks ago
  21. 2736169 [test][pipeline-e2e] Stabilize Hudi schema evolution waits by Leonard Xu · 4 weeks ago
  22. 7cf519b [test][pipeline-e2e] Stabilize RouteE2eITCase batch wait by Leonard Xu · 4 weeks ago
  23. b88ef14 [test][pipeline-e2e] Stabilize UdfE2eITCase event waits by Leonard Xu · 4 weeks ago
  24. ed7cb46 [test][pipeline-e2e] Stabilize TransformE2eITCase handoff waits by Leonard Xu · 4 weeks ago
  25. 7f90244 [test][pipeline-e2e] Stabilize SqlServerE2eITCase split handoff by Leonard Xu · 4 weeks ago
  26. a65fced [test][pipeline-e2e] Wait for MysqlToKafkaE2eITCase stream handoff by Leonard Xu · 4 weeks ago
  27. 6ef2e23 [test][pipeline-e2e] Stabilize MySqlToIcebergE2eITCase commits by Leonard Xu · 4 weeks ago
  28. 35f27ee [test][pipeline-e2e] Stabilize MySqlToHudiE2eITCase visibility waits by Leonard Xu · 4 weeks ago
  29. 931dc38 [test][pipeline-e2e] Add shared wait and checkpoint helpers by Leonard Xu · 4 weeks ago
  30. 03c499a [test][connector/tidb] Retry TiDB JDBC startup connections by Leonard Xu · 4 weeks ago
  31. 78baa80 [test][connector/oceanbase] Stabilize failover and startup waits by Leonard Xu · 4 weeks ago
  32. 6b7b3b1 [test][source-e2e][mongodb] Wait for MongoE2eITCase snapshot before changes by Leonard Xu · 4 weeks ago
  33. 8a6bbd8 [test][connector/mongodb] Tolerate newly-added table replay pair by Leonard Xu · 4 weeks ago
  34. 4c26663 [test][connector/sqlserver] Stabilize full types and timezone waits by Leonard Xu · 4 weeks ago
  35. b294f92 [test][pipeline-postgres] Avoid canceling stopped savepoint jobs by Leonard Xu · 4 weeks ago
  36. df11e13 [test][connector/postgres] Stabilize PostgresSourceReaderTest schema polling by Leonard Xu · 4 weeks ago
  37. 3427027 [test][connector/postgres] Stabilize NewlyAddedTableITCase failover waits by Leonard Xu · 4 weeks ago
  38. 19a9b64 [test][connector/mysql] Stabilize MySqlConnectorITCase waits by Leonard Xu · 4 weeks ago
  39. dfba99c [test][connector/mysql] Stabilize NewlyAddedTableITCase failover waits by Leonard Xu · 4 weeks ago
  40. d20dbc1 [test][ci] Keep E2E timezone selection on hour boundaries by Leonard Xu · 4 weeks ago
  41. b8edfcf [fix][mysql-source] Compare varbinary split keys by byte value by Leonard Xu · 4 weeks ago
  42. 6914d70 [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441) by yueqingshu · 4 weeks ago
  43. b5152df [minor][pipeline-connector/sqlserver] Align MySQL's schema restore process instead of per-record JDBC by Leonard Xu · 4 weeks ago
  44. a629dfa [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT (#4424) by mike · 4 weeks ago
  45. 504a4b4 [FLINK-39759][pipeline-connector/starrocks] Fix CHAR/VARCHAR mapping for utf8mb4 characters (#4447) by haruki · 5 weeks ago
  46. b451d9a [FLINK-39252][pipeline-connector/sqlserver] Polish docs and add SQL Server pipeline YAML e2e test by Leonard Xu · 6 weeks ago
  47. 97b36ce [FLINK-39252][pipeline-connector/sqlserver] Introduce SQLServer Pipeline Source connector by daishuyuan · 4 months ago
  48. 7355d76 [FLINK-39758] Fix DECIMAL OOB in SchemaMergingUtils (#4419) by haruki · 8 weeks ago
  49. 15288b3 [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint (#4360) by Spoorthi Basu · 8 weeks ago
  50. a97a5bc [FLINK-39621] Fix incremental-snapshot based sources may get stuck in binlog-backfill stage (#4388) by yuxiqian · 8 weeks ago
  51. b3acffe [FLINK-39582][postgres] Allow logical messages (#4387) by Joao Boto · 8 weeks ago
  52. be7d374 [FLINK-39757] Fix kafka sink could not serialize debezium json with column default values (#4416) by haruki · 8 weeks ago
  53. 31665ac [hotfix] Fix Postgres E2e test failure (#4421) by yuxiqian · 8 weeks ago
  54. 7acc625 [FLINK-39718][pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist. (#4406) by Thorne · 8 weeks ago
  55. 343778f [FLINK-39756] Fix unable to coerce complex types to STRING (#4414) by haruki · 9 weeks ago
  56. 26e6b73 [FLINK-38742][cdc-pipeline/postgres] Fix TIMESTAMPTZ type mapping to TIMESTAMP_LTZ (#4181) by A S Rakesh Krishna · 9 weeks ago
  57. 4b62e3d [minor][hotfix][pipeline-connector/fluss] Fix CdcAsFlussRow.java file location to match package declaration by haruki · 9 weeks ago
  58. 201aef6 [FLINK-39407][cdcup] Mount shared data volume on Flink containers for Paimon sink (#4408) by Jubin Soni · 9 weeks ago
  59. b6275e7 [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation (#4401) by Arvind Kandpal · 10 weeks ago
  60. 9e075ca [FLINK-39682] Fix unable to invoke TO_DATE with TIMESTAMP types (#4397) by yuxiqian · 2 months ago
  61. 3e1211e [FLINK-39696][runtime] Use source partition for distributed flush events (#4400) by Ran Tao · 2 months ago
  62. cbdd4da Set up default protection ruleset for default and release branches (#4399) by The Apache Software Foundation · 2 months ago
  63. a24b34f [FLINK-39684] Fix PaimonWriterHelper NullPointerException when handling REPLACE events (#4398) by yuxiqian · 2 months ago
  64. c347651 [FLINK-37731][pipeline-paimon]Support Postpone Bucket (#4386) by Thorne · 3 months ago
  65. 24ab548 [FLINK-39573][cdc][docs] Fix Build documentation CI startup_failure by replacing third-party rsync action (#4385) by yuanoOo · 3 months ago
  66. bb5982b [FLINK-39417] Fix GenericRecordData could not be [de]serialized in pipeline (#4374) by yuxiqian · 3 months ago
  67. b94d7b2 [FLINK-39563][paimon] Upgrade paimon dependency to 1.4.1 (#4384) by Pei Yu · 3 months ago
  68. fe79b4d [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image (#4111) by yuanoOo · 3 months ago
  69. eb3cdc0 [FLINK-38061][mysql] Make defensive copies of collections in SnapshotPendingSplitsState to prevent concurrent modification issues (#4379) by Jia Fan · 3 months ago
  70. 13cd198 [FLINK-39363][test] Fix flaky test PaimonSinkITCase (#4366) by Jia Fan · 4 months ago
  71. b48d8eb Add flink-cdc-flink*-compat to output t jar for source connector. (#4361) by Pei Yu · 4 months ago
  72. 1a1e81c [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties (#4351) by EricZeng · 4 months ago
  73. 23e23d6 [FLINK-39372][connect/mysql] Fix comparison logic for binlog filename with various digits (#4358) by yuxiqian · 4 months ago
  74. 209c0c6 [FLINK-39362][Docs] Fix broken/outdated connector download links and improve link maintenance strategy (#4356) by Kunni · 4 months ago
  75. ec244f1 [FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type (#4295) by Mingliang Zhu · 4 months ago
  76. 11a6ba7 [FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end (#4296) by Chengbing Liu · 4 months ago
  77. 1a65ad0 [ci] Fix constant nightly CI pipeline failure (#4354) by yuxiqian · 4 months ago
  78. 73305fb [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations (#4350) by yuxiqian · 4 months ago
  79. 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 months ago
  80. 68ee0c9 [FLINK-39346] Improve error message of invalid AddColumnEvents (#4353) by Pei Yu · 4 months ago
  81. 380da4a [FLINK-39344][doc] Fix inconsistencies in MySQL Pipeline Connector documentation (#4352) by yueqingshu · 4 months ago
  82. 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 · 4 months ago
  83. 6741c1d Clean up the compatibility code for Flink 1.19 in the e2e-tests module. (#4348) by Pei Yu · 4 months ago
  84. e4cf027 [FLINK-39329][MySQL] Improve error message for tables without primary key in incremental snapshot (#4342) by EricZeng · 4 months ago
  85. c408149 Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. (#4346) by Pei Yu · 4 months ago
  86. ccb5d4c [docs] Polish README.md (#4349) by yuxiqian · 4 months ago
  87. b569d64 FLINK-39288 [docs] Update pipeline connectors overview with Flink version specific jar names (#4345) by Kunni · 4 months ago
  88. a1b7d1e [FLINK-39300][connect/mysql] Reuse ObjectMapper as static constant to avoid repeated instantiation (#4330) by EricZ · 4 months ago
  89. b169f78 [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. (#4337) by Hongshun Wang · 4 months ago
  90. 619ab90 [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x (#4339) by Kunni · 4 months ago
  91. 48f8bf9 [docs] Reorder Flink CDC version mapping tables in descending order (#4340) by Leonard Xu · 4 months ago
  92. 133cc8e [doc][build] Update version to 3.7-SNAPSHOT by Kunni · 4 months ago
  93. b58561a [hotfix] [pipeline-connector/postgres] Fix wrong SchemaChangeEnabled option during delivery by Hongshun Wang · 4 months ago
  94. 1f64e57 [FLINK-39171][oracle-cdc] Fix Oracle pipeline connector wrong field case (#4292) by Jia Fan · 4 months ago
  95. 89d6f93 [release] Improve version handling in deploy_staging_jars.sh (#4335) by Kunni · 4 months ago
  96. 08f3fb8 [FLINK-39289][paimon] Supports executing TRUNCATE schema change events on tables with deletion-vectors.enabled:true set (#4327) by zexin.gong · 4 months ago
  97. 723615b [FLINK-39312][pipeline][hudi] Fix Hudi connector packaging to include flink-metrics-dropwizard dependency. (#4332) by Shuo Cheng · 4 months ago
  98. 283edb6 [FLINK-39297][doc] Update pipeline connectors overview for Flink CDC 3.6.0 (#4329) by Kunni · 4 months ago
  99. 3d405fb [FLINK-39295] Update MySQL docs to reflect MySQL 8.4+ support (#4331) by yuxiqian · 4 months ago
  100. 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 · 4 months ago