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