Google Git
Sign in
apache / flink-cdc / HEAD
  1. 381193f [FLINK-38278][postgres-pipeline] supported array type field. (#4108) by ouyangwulin · 9 days ago master
  2. f6197d2 [FLINK-37738][docs] Fix Postgres Chinese and English document contents (#4109) by ouyangwulin · 11 days ago
  3. 0c9c113 [FLINK-38157][connect/postgres] Supports assigning unbounded chunk first (#4103) by ouyangwulin · 2 weeks ago
  4. 0842fee [FLINK-37959][postgres]Supports all pgsql field types like debezium (#4086) by ouyangwulin · 2 weeks ago
  5. a0699ac [FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. (#4100) by Hongshun Wang · 3 weeks ago
  6. 10e84ca [FLINK-38248][pipeline-connector][paimon][starrocks][doris] The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. (#4096) by suhwan · 3 weeks ago
  7. ca602f9 [FLINK-38244] When the column name of mysql supports case-insensitive, fix the error that column name not being found. (#4095) by Hongshun Wang · 3 weeks ago
  8. f9b9f0c [Flink-38238] Support varchar(0) and map to cdc string type (#4097) by proletarians · 3 weeks ago
  9. fea9807 [FLINK-38111] [oceanbase] Migrate OceanBase CDC Connector from LogProxy to Binlog Service. (#4061) by yuanoOo · 3 weeks ago
  10. d0fe46c [FLINK-38045] Build createTableEventCache using TableSchemas from split and Make transform operator stateless (#4056) by proletarians · 3 weeks ago
  11. 16fa17e [FLINK-38204][pipeline-connector][maxcompute] Use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. #4094 by proletarians · 3 weeks ago
  12. 379e5c9 [hotfix][doc] Update uses of Upload documentation in build_docs.yml. (#4093) by Kunni · 3 weeks ago
  13. 6788ff5 [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory (#4075) by Lanny Boarts · 3 weeks ago
  14. b937fdc [FLINK-37835] Fix NoPointException when start with latest-offset. (#4091) by proletarians · 3 weeks ago
  15. 35504bd [FLINK-38059][doc] Add fluss pipeline connector documentation (#4088) by Junbo Wang · 4 weeks ago
  16. b67ba29 [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely (#4044) by yuxiqian · 4 weeks ago
  17. 06ab765 [FLINK-38142] Upgrading the Paimon version to 1.2.0 (#4066) by junmuz · 4 weeks ago
  18. 224a075 [FLINK-37905][runtime] Fix transform failure with non-ascii string literals (#4038) by yuxiqian · 4 weeks ago
  19. 5bf2564 [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace (#4080) by Chao Zhang · 4 weeks ago
  20. 81f2518 [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability (#4082) by Junbo Wang · 4 weeks ago
  21. 190915d [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type (#4076) by Chao Zhang · 4 weeks ago
  22. 4c479fd [FLINK-38184] one time of GetCopyOfBuffer is enough When serializing split. (#4073) by Hongshun Wang · 4 weeks ago
  23. 42f91a8 [tests][pipeline-connector/fluss] Add MySQL to Fluss E2e IT case (#4057) by yuxiqian · 4 weeks ago
  24. 998e023 [FLINK-38185][pipeline-connector][iceberg] Correctly handle the type conversion of TIMESTAMP_TITH_TIME_ZONE. (#4074) by Kunni · 5 weeks ago
  25. 7d93fc1 [minor] Fix potential sql connection statement issue (#4069) by Kunni · 5 weeks ago
  26. f58158a [FLINK-38141][pipeline-connector/iceberg] Fix iceberg connector incorrect type mapping (#4070) by Chao Zhang · 5 weeks ago
  27. 5eaf9eb [FLINK-38134][cdc-common] Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference(#4065) by tbpure · 5 weeks ago
  28. a26f41d [FLINK-35670][pipeline-connector][postgres] Add PostgreSQL source. (#3968) by ouyangwulin · 5 weeks ago
  29. 332ec71 [FLINK-38156][hotfix] Fix pipeline E2E tests. (#4068) by Kunni · 5 weeks ago
  30. bb00ed5 [docs] Update mysql-cdc some param description by Xin Gong · 5 weeks ago
  31. 13c2456 [docs] improve doc for PostgreSQL (#4055) by Thorne · 8 weeks ago
  32. 8437bc9 [FLINK-38065][cdc-connector/pg] Use curly braces in PostgresOffset#toString() by Sergei Morozov · 8 weeks ago
  33. 2139824 [FLINK-37958][pipeline-connector/fluss] Introduce Fluss Pipeline Sink connector by Hongshun Wang · 9 weeks ago
  34. 3d22824 [Fix][Docs] Quick Start mysql-to-starrocks Flink Version Incorrect (#4052) by suntectec · 9 weeks ago
  35. 61de209 docs: updated StarRocks documentation link (#4054) by zhuxt2015 · 9 weeks ago
  36. 43d7507 Update starrocks.md (#4021) by zhuxt2015 · 9 weeks ago
  37. 23a1c2e [hotfix][ci] Add missing Iceberg unit tests & split pipeline connector UT into stages (#4046) by yuxiqian · 2 months ago
  38. 49fe26d [FLINK-37738][cdc-connector][postgres] Support read changelog as append only mode (#4005) by Hongshun Wang · 3 months ago
  39. 1c0c5af [FLINK-37634][pipeline-connector/mysql]When the table name of mysql supports size sensitive, fix the error that table name not being found. (#3996) by linjianchang · 3 months ago
  40. 1454b36 [FLINK-37891][docs]Remove SQL Server CDC documentation for initial-only (#4037) by Sergei Morozov · 3 months ago
  41. 2fcf6f2 [FLINK-37860][pipeline-connector/paimon]Fix Committer.createContext not passing OperatorStateStore correctly (#4029) by MOBIN · 3 months ago
  42. 9c84d64 [FLINK-37909][source-connector/mongodb] Fix hearbeat manager not updated after reconnect (#4039) by Sachin Mittal · 3 months ago
  43. 0faf387 [hotfix] Remove useless imports. (#4023) by Tianzhu Wen · 3 months ago
  44. 9d684e2 [FLINK-37223] Add the missing documents and parameters of MySQL CDC. (#3894) by Kunni · 3 months ago
  45. e8f9ff0 [FLINK-37604] Generate static UIDs for pipeline operators (#3977) by Sergei Morozov · 3 months ago
  46. 447b8d6 [FLINK-37465][docs] Update options for OceanBase connector (#3946) by Shawn Huang · 3 months ago
  47. ae2fb5a [FLINK-37347][DOCS] Support any column as chunk key column (postgres, orcale, db2, sqlserver) (#3924) by SeungMin · 3 months ago
  48. 29bee72 [FLINK-37839][tools] Fix source release package contains ._* files (#4025) by MOBIN · 3 months ago
  49. 6b8c5f3 [FLINK-37774][sqlserver] Fix SQL Server CDC connector incorrectly handles special characters in database and table names (#4014) by Sergei Morozov · 3 months ago
  50. a91f8b7 [FLINK-37577][pipeline-connector/paimon] Fix unable to apply column comments to Paimon tables (#4022) by North Lin · 4 months ago
  51. cc561c0 [docs] minor updates to Iceberg sink reference (#4018) by Marta Paes · 4 months ago
  52. a390c98 [FLINK-36844][docs]Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz (#3847) by Hongshun Wang · 4 months ago
  53. aaa2a48 [hotfix][cdc][docs] Build 3.4 docs and mark it as stable by Kunni · 4 months ago
  54. f3f51b5 [FLINK-36999][cdc-source-connectors] When the source field type is decimal and the value is null, a null pointer exception occurs during deserialization by linjianchang · 4 months ago
  55. adfa202 [docs] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation (#4016) by Junbo wang · 4 months ago
  56. 7a57f55 [FLINK-37128][cdc-connector-mysql] Binlog reader skip shouldEmit filter when snapshot reader skip backfill (#3874) by Junbo wang · 4 months ago
  57. ceffbc0 [hotfix] Fix environment variable check for FLINK_CDC_HOME in YarnApplicationDeploymentExecutor. (#4012) by Tianzhu Wen · 4 months ago
  58. ecaf82e [build] Update version to 3.5-SNAPSHOT by Kunni · 4 months ago
  59. a991169 [FLINK-37462][cdc-runtime] Fix consecutive schema change requests might be overwritten by yuxiqian · 4 months ago
  60. 250ab43 [FLINK-37741][cdc-runtime] Fix transform operator performance degradation by yuxiqian · 4 months ago
  61. c9a2732 [FLINK-37509][base&mysql] Increment scan source no need to buffer data when enable skipping backfill. (#3964) by Hongshun Wang · 4 months ago
  62. e35180d [FLINK-37453][tests] Port state migration tests from Ruby to Java by yuxiqian · 4 months ago
  63. 3f1c893 [FLINK-35093][cdc-source/postgres] Support COMMITTED_OFFSET startup mode to resume from existing replication slot by Vinh Pham · 4 months ago
  64. 37a2e02 [FLINK-36973][cdc-transform] DateFormat function supports LocalZonedTimestampData type by yuxiqian · 4 months ago
  65. b5cfc0b [docs][minor] Improve the YAML example docs by Robin Moffatt · 4 months ago
  66. c2230d5 [FLINK-36742][cdc-base] Filter unacked split for no capture tables when task restore from state by Xin Gong · 4 months ago
  67. b89d84f [FLINK-37566][source-connector/mysql] Avoid processing binlog event of excluded tables by Kunni · 4 months ago
  68. e05f797 [FLINK-37587][runtime] Fix error when adding a column using transform which has the same column name with one column of source table. (#3974) by Kunni · 4 months ago
  69. 612ff5d [FLINK-37713][runtime] Fix SchemaManager was recreated in SchemaRegistry after job failover by Kunni · 4 months ago
  70. 4bc7366 [FLINK-37104][cdc-transform] Refactor transform module and cleanup code by yuxiqian · 5 months ago
  71. 7c47f7a [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted by Hongshun Wang · 5 months ago
  72. 85dafb1 [hotfix] [base] Fix the serialization error occurring with table names containing dot by zhangzheng · 1 year, 4 months ago
  73. 1993444 [FLINK-34874][source-connector/mongodb] Support initial.snapshotting.pipeline related configs in Table API by Runkang He · 5 months ago
  74. 2729ad0 [FLINK-36793][source-connector/oracle] Fix the problem of uneven splits caused by Oracle ROWID type comparison by linjianchang · 5 months ago
  75. e7760d4 [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table by North Lin · 5 months ago
  76. 61702a6 [FLINK-36931][cdc-runtime] Supports batch pipeline for CDC YAML by Wink · 5 months ago
  77. 4cf54c6 [FLINK-37706][source-connector/oceanbase][tests] Use fixed docker image version instead of latest for test by Leonard Xu · 5 months ago
  78. 72345f0 [FLINK-37507][source-connector/mysql] Fix MySQL CDC accidentally captures common-prefix database when `scan.binlog.newly-added-table` is enabled by yuxiqian · 5 months ago
  79. 4743399 [FLINK-37578][cdc-runtime] Fix distributed schema registry exposes bad internal state accidentally by yuxiqian · 5 months ago
  80. 241973b [FLINK-36061][pipeline-connector/iceberg] Introduce Iceberg Sink Connector by Kunni · 5 months ago
  81. bb2fce2 [FLINK-37696][tests][postgres] Replace postgres image to official pg 14 and adjust test to use pgoutput plugin by Hongshun Wang · 5 months ago
  82. 441eec8 [FLINK-37332][cdc-base] Support any column as chunk key column by SeungMin · 5 months ago
  83. 95fe4d3 [FLINK-36684][cdc-connector/mysql] Support read changelog as append only mode by Runkang He · 5 months ago
  84. 851c37e [FLINK-37654][docs][pipeline-connector/doris] Enhance Doris connector docs with configuration details and type compatibility by Petrichor · 5 months ago
  85. ec1e0ab [hotfix][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck by Hongshun Wang · 5 months ago
  86. 3460ba2 [hotfix][minor] Fix CI failure due to code checkstyle by MOBIN-F · 5 months ago
  87. b61b136 [FLINK-36611][pipeline-connector/kafka] Rename sink.debezium-json.include-schema.enabled to debezium-json.include-schema.enabled by MOBIN-F · 5 months ago
  88. 4baee8c [FLINK-37000][pipeline-connector][mysql] Fix MySQL CDC could not handle datetime prior to 1970 properly (#3834) by yuxiqian · 5 months ago
  89. 1646715 [FLINK-37484][cdc-connector] unevenly chunk split also enables unbounded-chunk-first.enabled. (#3954) by Hongshun Wang · 5 months ago
  90. 69ec337 [minor][pipeline-connector/doris] Fix deprecated method usage in DorisSchemaChangeManager by chenhongyu · 5 months ago
  91. 3457a92 [FLINK-36611][pipeline-connector/kafka] Support output schema for Kafka debezium-json format by MOBIN · 5 months ago
  92. 0dde22c [hotfix][cli] Fix duplicated option in CliFrontendOptions by lidoudou1993 · 5 months ago
  93. f072bf1 [docs][zh] Translate "Table ID" Page for Flink CDC Chinese Documentation by Kevin Caesar · 5 months ago
  94. 2e4abdb [FLINK-36683][cdc-connector/mongo] Support metadata 'row_kind' virtual column by Runkang He · 5 months ago
  95. 3447798 [FLINK-37577][pipeline-connector/paimon] Enable waitCompaction feature in PaimonWriter only when deletion-vectors.enabled option enabled by Kunni · 5 months ago
  96. b161521 [FLINK-37572][pipeline-connector/paimon] Shuffle Event by bucket and tableid to avoid data skew by Kunni · 5 months ago
  97. d6f8bd4 [FLINK-37529][cdc-connector] Add flink-cdc-common module to all sql jars (#3962) by Hongshun Wang · 5 months ago
  98. 8ea04ec [hotfix][ci] Prevent Nightly actions from being triggered by forks (#3969) by gongzhongqiang · 5 months ago
  99. da40727 [FLINK-37371][cdc-connector/postgresql] Postgres CDC incremental source fails to handle upper-case table and column names by Sergei Morozov · 5 months ago
  100. a6eb0f8 [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception by yuxiqian · 5 months ago