Google Git
Sign in
apache/flink-cdc/HEAD
  1. 23fb108 [FLINK-40340][mysql] Fix schema change exception when parsing MySQL zerofill data types without unsigned keyword (#4500) by Jzjsnow · 29 hours ago master
  2. 4f239e7 [hotfix][runtime] Respect UDF precedence during type validation (#4505) by haruki · 2 days ago
  3. 4478405 [FLINK-40441][pipeline-connector][postgres] Fix HikariCP class conflict in Flink CDC Postgres connector (#4511) by Jzjsnow · 3 days ago
  4. 48944c6 [FLINK-40409][runtime] CDC YAML supports inline Python UDF definition (#4501) by yuxiqian · 3 days ago
  5. 4e3767a [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits (#4503) by haruki · 4 days ago
  6. 53fe0f9 [FLINK-40411][runtime] Introduce OpenAI-compatible model client (#4507) by haruki · 4 days ago
  7. cc384a0 [FLINK-40313][runtime] Support nested collection functions in Transforms (#4496) by haruki · 8 days ago
  8. e3f0caf [FLINK-39568][runtime] Introduce AI model client function API (#4504) by haruki · 9 days ago
  9. 91040de [FLINK-39824][flink-connector-debezium] Cache relational table filter results (#4422) by Ran Tao · 10 days ago
  10. fdacb41 [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform (#4492) by haruki · 11 days ago
  11. ff26ee2 [FLINK-40312] [runtime] Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform (#4495) by haruki · 12 days ago
  12. 55cccc9 [FLINK-40223][runtime] Support additional Flink SQL string functions in YAML Transform (#4488) by haruki · 2 weeks ago
  13. 78b4fef [FLINK-40337][runtime] Preserve operator precedence in generated Janino expressions (#4499) by haruki · 2 weeks ago
  14. d1ae9f1 [FLINK-40239][runtime] Support additional Flink SQL regular expression functions in YAML Transform (#4491) by haruki · 2 weeks ago
  15. 6e8ef16 [FLINK-40274][cdc-cli] Remove unsupported kubernetes-session from target option help message (#4493) by jj.lee · 3 weeks ago
  16. 308359e [FLINK-40007][connect/postgres] Fix snapshot fetch size conf does not take effect (#4453) by wudi · 3 weeks ago
  17. aa42119 [FLINK-39732][cdc-base] Introduce ObjectIdDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) (#4409) by Hongshun Wang · 3 weeks ago
  18. c45eb56 [hotfix][pipeline-connector/sqlserver] Align pipeline default value with SQL API by Leonard Xu · 4 weeks ago
  19. 61e0d2c [FLINK-40202][cdc-base] Init enumerator metrics before opening SnapshotSplitAssigner to avoid ConcurrentModificationException (#4480) by naivedogger · 4 weeks ago
  20. 85b83fc [FLINK-40151][runtime] Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation (#4474) by haruki · 4 weeks ago
  21. a52fe0d [FLINK-40159][connect/hudi] Support Hive sync for Hudi pipeline sink (#4476) by BreadS · 5 weeks ago
  22. 124bffe [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478) by haruki · 5 weeks ago
  23. be5399f [FLINK-38647][connect/postgres] Improve error message when REPLICA IDENTITY FULL is not configured (#4439) by BreadS · 5 weeks ago
  24. b18f95e [FLINK-39777][common] Add TableId partitioning strategy configuration (#4423) by haruki · 6 weeks ago
  25. cd8b8a9 [docs][connect/postgres] Improve Incremental Snapshot Reading formatting and references (#4472) by nhuantho · 6 weeks ago
  26. bdf32d7 [hotfix][ci] Exclude Flink compatibility modules from Javadocs generation (#4470) by yuxiqian · 6 weeks ago
  27. 36d2121 [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink (#4471) by haruki · 6 weeks ago
  28. 4371a4e [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner (#4469) by Purushottam Sinha · 6 weeks ago
  29. e780a7c [FLINK-39760][postgres] Fix missing JTS core dependency of PostgreSQL YAML connector (#4467) by haruki · 6 weeks ago
  30. 0e07178 [hotfix] Bump Mockito for JDK 17 tests (#4463) by yuxiqian · 6 weeks ago
  31. fd5b636 [FLINK-40091][connect/paimon] Upgrade Paimon SDK to 1.4.2 (#4465) by Pei Yu · 6 weeks ago
  32. db6178d [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions (#4380) by yuxiqian · 7 weeks ago
  33. e1e9c93 [FLINK-40043][paimon] Fix NoSuchElementException when restoring PaimonSink with increased parallelism. (#4457) by Pei Yu · 7 weeks ago
  34. 279278a [FLINK-39934][postgres] Fix invalid tables format error message (#4442) by Ran Tao · 7 weeks ago
  35. accee65 [test][pipeline-e2e] Share stream split readiness wait by Leonard Xu · 7 weeks ago
  36. c32c651 [test][pipeline-e2e] Skip checkpointing non-streaming Iceberg job by Leonard Xu · 7 weeks ago
  37. 1357fe1 [test] Keep stabilization changes semantically strict by Leonard Xu · 7 weeks ago
  38. 2736169 [test][pipeline-e2e] Stabilize Hudi schema evolution waits by Leonard Xu · 7 weeks ago
  39. 7cf519b [test][pipeline-e2e] Stabilize RouteE2eITCase batch wait by Leonard Xu · 7 weeks ago
  40. b88ef14 [test][pipeline-e2e] Stabilize UdfE2eITCase event waits by Leonard Xu · 7 weeks ago
  41. ed7cb46 [test][pipeline-e2e] Stabilize TransformE2eITCase handoff waits by Leonard Xu · 7 weeks ago
  42. 7f90244 [test][pipeline-e2e] Stabilize SqlServerE2eITCase split handoff by Leonard Xu · 7 weeks ago
  43. a65fced [test][pipeline-e2e] Wait for MysqlToKafkaE2eITCase stream handoff by Leonard Xu · 7 weeks ago
  44. 6ef2e23 [test][pipeline-e2e] Stabilize MySqlToIcebergE2eITCase commits by Leonard Xu · 7 weeks ago
  45. 35f27ee [test][pipeline-e2e] Stabilize MySqlToHudiE2eITCase visibility waits by Leonard Xu · 7 weeks ago
  46. 931dc38 [test][pipeline-e2e] Add shared wait and checkpoint helpers by Leonard Xu · 7 weeks ago
  47. 03c499a [test][connector/tidb] Retry TiDB JDBC startup connections by Leonard Xu · 7 weeks ago
  48. 78baa80 [test][connector/oceanbase] Stabilize failover and startup waits by Leonard Xu · 7 weeks ago
  49. 6b7b3b1 [test][source-e2e][mongodb] Wait for MongoE2eITCase snapshot before changes by Leonard Xu · 7 weeks ago
  50. 8a6bbd8 [test][connector/mongodb] Tolerate newly-added table replay pair by Leonard Xu · 7 weeks ago
  51. 4c26663 [test][connector/sqlserver] Stabilize full types and timezone waits by Leonard Xu · 7 weeks ago
  52. b294f92 [test][pipeline-postgres] Avoid canceling stopped savepoint jobs by Leonard Xu · 7 weeks ago
  53. df11e13 [test][connector/postgres] Stabilize PostgresSourceReaderTest schema polling by Leonard Xu · 7 weeks ago
  54. 3427027 [test][connector/postgres] Stabilize NewlyAddedTableITCase failover waits by Leonard Xu · 7 weeks ago
  55. 19a9b64 [test][connector/mysql] Stabilize MySqlConnectorITCase waits by Leonard Xu · 7 weeks ago
  56. dfba99c [test][connector/mysql] Stabilize NewlyAddedTableITCase failover waits by Leonard Xu · 7 weeks ago
  57. d20dbc1 [test][ci] Keep E2E timezone selection on hour boundaries by Leonard Xu · 7 weeks ago
  58. b8edfcf [fix][mysql-source] Compare varbinary split keys by byte value by Leonard Xu · 7 weeks ago
  59. 6914d70 [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441) by yueqingshu · 7 weeks ago
  60. b5152df [minor][pipeline-connector/sqlserver] Align MySQL's schema restore process instead of per-record JDBC by Leonard Xu · 7 weeks ago
  61. a629dfa [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT (#4424) by mike · 8 weeks ago
  62. 504a4b4 [FLINK-39759][pipeline-connector/starrocks] Fix CHAR/VARCHAR mapping for utf8mb4 characters (#4447) by haruki · 8 weeks ago
  63. b451d9a [FLINK-39252][pipeline-connector/sqlserver] Polish docs and add SQL Server pipeline YAML e2e test by Leonard Xu · 10 weeks ago
  64. 97b36ce [FLINK-39252][pipeline-connector/sqlserver] Introduce SQLServer Pipeline Source connector by daishuyuan · 5 months ago
  65. 7355d76 [FLINK-39758] Fix DECIMAL OOB in SchemaMergingUtils (#4419) by haruki · 3 months ago
  66. 15288b3 [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint (#4360) by Spoorthi Basu · 3 months ago
  67. a97a5bc [FLINK-39621] Fix incremental-snapshot based sources may get stuck in binlog-backfill stage (#4388) by yuxiqian · 3 months ago
  68. b3acffe [FLINK-39582][postgres] Allow logical messages (#4387) by Joao Boto · 3 months ago
  69. be7d374 [FLINK-39757] Fix kafka sink could not serialize debezium json with column default values (#4416) by haruki · 3 months ago
  70. 31665ac [hotfix] Fix Postgres E2e test failure (#4421) by yuxiqian · 3 months ago
  71. 7acc625 [FLINK-39718][pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist. (#4406) by Thorne · 3 months ago
  72. 343778f [FLINK-39756] Fix unable to coerce complex types to STRING (#4414) by haruki · 3 months ago
  73. 26e6b73 [FLINK-38742][cdc-pipeline/postgres] Fix TIMESTAMPTZ type mapping to TIMESTAMP_LTZ (#4181) by A S Rakesh Krishna · 3 months ago
  74. 4b62e3d [minor][hotfix][pipeline-connector/fluss] Fix CdcAsFlussRow.java file location to match package declaration by haruki · 3 months ago
  75. 201aef6 [FLINK-39407][cdcup] Mount shared data volume on Flink containers for Paimon sink (#4408) by Jubin Soni · 3 months ago
  76. b6275e7 [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation (#4401) by Arvind Kandpal · 3 months ago
  77. 9e075ca [FLINK-39682] Fix unable to invoke TO_DATE with TIMESTAMP types (#4397) by yuxiqian · 3 months ago
  78. 3e1211e [FLINK-39696][runtime] Use source partition for distributed flush events (#4400) by Ran Tao · 3 months ago
  79. cbdd4da Set up default protection ruleset for default and release branches (#4399) by The Apache Software Foundation · 3 months ago
  80. a24b34f [FLINK-39684] Fix PaimonWriterHelper NullPointerException when handling REPLACE events (#4398) by yuxiqian · 3 months ago
  81. c347651 [FLINK-37731][pipeline-paimon]Support Postpone Bucket (#4386) by Thorne · 3 months ago
  82. 24ab548 [FLINK-39573][cdc][docs] Fix Build documentation CI startup_failure by replacing third-party rsync action (#4385) by yuanoOo · 4 months ago
  83. bb5982b [FLINK-39417] Fix GenericRecordData could not be [de]serialized in pipeline (#4374) by yuxiqian · 4 months ago
  84. b94d7b2 [FLINK-39563][paimon] Upgrade paimon dependency to 1.4.1 (#4384) by Pei Yu · 4 months ago
  85. fe79b4d [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image (#4111) by yuanoOo · 4 months ago
  86. eb3cdc0 [FLINK-38061][mysql] Make defensive copies of collections in SnapshotPendingSplitsState to prevent concurrent modification issues (#4379) by Jia Fan · 4 months ago
  87. 13cd198 [FLINK-39363][test] Fix flaky test PaimonSinkITCase (#4366) by Jia Fan · 5 months ago
  88. b48d8eb Add flink-cdc-flink*-compat to output t jar for source connector. (#4361) by Pei Yu · 5 months ago
  89. 1a1e81c [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties (#4351) by EricZeng · 5 months ago
  90. 23e23d6 [FLINK-39372][connect/mysql] Fix comparison logic for binlog filename with various digits (#4358) by yuxiqian · 5 months ago
  91. 209c0c6 [FLINK-39362][Docs] Fix broken/outdated connector download links and improve link maintenance strategy (#4356) by Kunni · 5 months ago
  92. ec244f1 [FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type (#4295) by Mingliang Zhu · 5 months ago
  93. 11a6ba7 [FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end (#4296) by Chengbing Liu · 5 months ago
  94. 1a65ad0 [ci] Fix constant nightly CI pipeline failure (#4354) by yuxiqian · 5 months ago
  95. 73305fb [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations (#4350) by yuxiqian · 5 months ago
  96. 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 · 5 months ago
  97. 68ee0c9 [FLINK-39346] Improve error message of invalid AddColumnEvents (#4353) by Pei Yu · 5 months ago
  98. 380da4a [FLINK-39344][doc] Fix inconsistencies in MySQL Pipeline Connector documentation (#4352) by yueqingshu · 5 months ago
  99. 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 months ago
  100. 6741c1d Clean up the compatibility code for Flink 1.19 in the e2e-tests module. (#4348) by Pei Yu · 5 months ago