Skip to content

Releases: apache/flink-cdc

Release-2.3.0

10 Nov 01:56
@leonardBang leonardBang
release-2.3.0
c65f9e0
Compare
Choose a tag to compare
Release-2.3.0

Release Notes

Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.3

Features and Improvements

  1. [mysql] Improve error message under the case that start reading from earliest but schema change happened before (#1724)
  2. [mysql] Use event filter to drop events earlier than the specified timestamp in timestamp startup mode (#1724)
  3. [docs][oracle] Add new introduced config options from incremental snapshot framework (#1718)
  4. [docs][oceanbase][zh] Update outdated sections and translate them to Chinese
  5. [hotfix][docs] Add link for Oceanbase ZH docs
  6. [docs][oceanbase] Add Chinese documents for oceanbase-cdc connector(#1611)
  7. [db2] Fix stream api example in db2 doc. (#1725)
  8. [oracle] Add missing supported config options for oracle table source (#1720)
  9. [mysql] Fix MySqlBinlogSplitAssigner may reassign split after exception restart (#1713)
  10. [docs] Repair Connector Data Type links
  11. [docs] Update the connector download link in the document
  12. [docs] Update the flink cdc picture with supported database vendors.
  13. [tidb] Fix unstable TiDB region changed test. (#1702)
  14. [docs][mongodb] Add docs for MongoDB incremental source
  15. [oracle][mysql] Improve the Oracle all data types test and clean up debug logs
  16. [oracle] Properly support TIMESTAMP_LTZ type for oracle cdc connector
  17. [oracle]support use user given column as split column
  18. [oracle][minor] Clean up useless methods and classes
  19. [oracle] Parallel read supports startup of startupOptions
  20. [oracle] Add full type field test
  21. [oracle]OracleTableSource support splitSize, fetchSize ,connectMaxRetries, connectionPoolSize and add test
  22. [hotfix][oracle][db2] Update the license header
  23. [cdc-base][oralce] Remove useless method of JdbcSourceFetchTaskContext
  24. [cdc-base][oracle] Improve the base methods base on Oracle specific requirements
  25. [oracle] Support custom url for incremental snapshot source
  26. [oracle] Introduce SCAN_INCREMENTAL_SNAPSHOT_ENABLED option for OracleTableSourceFactory
  27. [minor][oracle] Improve tests and code format
  28. [oracle] Ignore testCheckpointAndRestore util DBZ-5245 and DBZ-4936 fix
  29. [oracle][test] Add tests for Oracle incremental snapshot source
  30. [oracle] Use ROWID as split column and replace limit syntax with ROWNUM
  31. [oracle] Let LogMinerStreamingChangeEventSource do not rely on oracle table LOG_MINING_FLUSH
  32. [oracle] Use Incremental Snapshot Framework for Oracle CDC Connector (#1079)
  33. [docs] Bump Flink version to 1.16.0
  34. [common] Bump Flink version to 1.16.0
  35. [docs][db2] Add db2 to README.md (#1699)
  36. [tidb] Checkpoint is not updated long after a task has been running (#1686)
  37. [hotfix] Add method getMaxResolvedTs back to class CDCClient. (#1695)
  38. [docs] Bump connector version to flink 1.15.2 in docs (#1684)
  39. [tidb] Fix data lost when region changed (#1632)
  40. [hotfix][docs] Correct reference link for DB2 docs (#1683)
  41. [mysql] Update docs of specifying starting offset feature of MySQL CDC source
  42. [hotfix][mysql] Remove unused constructor in MySqlTableSource
  43. [mysql] Support starting reading binlog from earliest offset / specific offset / timestamp (#1661)
  44. [mongodb] Support incremental snapshot for MongoDB CDC Connector
  45. [cdc-base] Extract a higher level IncrementalSource independent of JDBC dialects
  46. [hotfix][docs] Fix db2 doc download link (#1681)
  47. [docs][db2] Add Db2 CDC connector doc link
  48. [docs][db2] Add Db2 cdc connector docs
  49. [build][db2] Add Db2 pipeline script
  50. [e2e][db2] Add Db2 e2e test
  51. [db2] Add sql connector for Db2 CDC (#1626)
  52. [db2] Introduce Db2 cdc connector (#450)
  53. [tidb] Fix data loss in tidb-cdc when switch from snapshot read to change event read (#1207)
  54. [hotfix][cdc-base] Fix OffsetFactory is not initialized when restored from checkpoint (#1657)
  55. [common] Bump Flink version to 1.15.2 (#1504)
  56. [cdc-base] Abstract naming for variables of incremental framework (#1646)
  57. [mysql] ChunkSplitter supports to snapshot when splitting chunks for a table (#1463)
  58. [cdc-base] Fix StreamSplit's endingOffset of StreamSplitAssigner (#1659)
  59. [cdc-base] JdbcSourceConfig can be template type of DataSourceDialect (#1639)
  60. [mysql] Use the latest received meta of binlog split when request the next meta (#1479)
  61. [minor] Use Collections.singletonList instead of Arrays.asList if possible (#1569)
  62. [oceanbase] Add new deserialization schema with runtime converter (#1356)
  63. [mysql] Avoid duplicate split requests when add new table (#1156)
  64. [postgres] Upgrade org.postgresql:postgresql from 42.2.14 to 42.2.26 for CVE-2022-31197 (#1616)
  65. [test][e2e] Upgrade org.postgresql:postgresql from 42.3.1 to 42.2.26 for CVE-2022-31197(#1616)
  66. [hotfix][typo] Fix typo from schemaLess to schemaless
  67. [cdc-base] Reduce the memory usage of JM by sharing table schemas between splits
  68. [cdc-base] Release the scan fetcher thread resource after reading finished (#1619)
  69. [cdc-base] Optimize pure binlog phase check logic to improve performance (#1620)
  70. [cdc-base] Let all records of one snapshot split don't cross checkpoints (#1622)
  71. [postgres] Introduce changelog mode configuration with upsert/all modes
  72. [common] Introduce changelog mode configuration with upsert/all modes
  73. [hotfix][docs] Fix docs for scan.incremental.snapshot.chunk.size (#1617)
  74. [cdc-base] Adopt streaming merge during snapshotSplit scan to avoid OOM
  75. [docs][oceanbase][zh] Add video tutorials that synchronizes data from OceanBase to Elasticsearch (#1604)
  76. [docs][oceanbase] Add video tutorials that synchronizes data from OceanBase to Elasticsearch (#1605)
  77. [mysql] Fix parse error when ALTER SQL statement contains default string value and collate. (#1544)
  78. [docs][mysql] Add regex examples for multiple tables (#1564)
  79. [oceanbase] Shade apache commons dependency to avoid class conflict (#1532)
  80. [postgres] add geometry type support. (#1554)
  81. [build] Polish CI scripts and remove useless code (#1540)
  82. [mysql] fix parsing ddl error when use string default values for numeric types (#1522)
  83. [mysql] Enumerate captured tables lazily (#1507)
  84. [mysql] Reduce the memory usage of JM by sharing table schemas between splits (#1523)
  85. [hotfix][docs] Fix comment typo in MysqlSnapshotSplit (#1513)
  86. [mysql] Let all records of one snapshot split don't cross checkpoints (#1505)
  87. [tests] Remove usage of deprecated EnvironmentSettings.Builder#useBlinkPlanner (#1493)
  88. [cdc-base][mysql] Fix split key comparison when may contain different types (#1499)
  89. [docs][mysql] Update the description of mysql server-time-zone option (#1497)
  90. [mysql] Use local timezone as the default value of 'server-time-zone' option (#1407)
  91. [docs][postgres] Add two frequently debezium options in Postgres connector document (#1142)
  92. [mongodb] Allow mongo ARRAY to be converted to string type in Flink (#1475)
  93. [hotfix][docs] Fix the page links in MySQL Chinese document (#1466)
  94. [oceanbase][test] Use memory mode of obcdc and double startup timeout duration (#1474)
  95. [mysql][polardbx] Stop container timely in tests (#1468)
  96. [mysql][ploardbx] Support all charsets in column level (#1166)
  97. [mongodb] Expose updateLookup option for stream source. (#1461)
  98. [oceanbase] Use utc offset as 'server-time-zone' option's default value (#1443)
  99. [mysql][minor] Skip capture newly added tables according snapshotassigner's status (#1449)
  100. [polardbx][test] Bump the polardb-x image version from 2.0.1 to 2.10 (#1423)
  101. [build][test] Specify surefire provider to surefire-junit47 (#1423)
  102. [hotfix][docs] Fix typo in bug report doc (#1460)
  103. [minor][oracle] Rename JdbcConfigurationUtil to OracleJdbcUrlUtils
  104. [oracle] Support custom JDBC URL for Oracle (#1258)
  105. [docs] Correct the data type of 'server-id' option to String (#1444)
  106. [hotfix][test] Fix MySqlSourceITCase failure due to StreamExecutionEnvironment#getConfiguration returned unmodifiable object (#1446)
  107. [test] Fix tests missed 'update_before' records if the primary keys of source and sink are different (#1451)
  108. [hotfix][oracle] Fix the shell script interpreter assignment should be at first line (#1452)
  109. [hotfix][tidb-cdc] TiDB CDC dealUnsignedColumnValue throw NullPointerException. (#1448)
  110. [polardbx][test] Rename PolardbxSourceTCase to PolardbxSourceITCase (#1447)
  111. [mysql] Enable pass custom jdbc properties for debezium mysql connection (#1217)
  112. [mysql] Release the debezium reader thread resources after reading finished (#1358)
  113. [oceanbase] Introduce 'table-list' option to support capture list of tables (#1369)
  114. [cdc-base] Flink CDC base registers the identical history engine on multiple tasks (#1340)
  115. [hotfix][mysql] Fix compile error due to merge conflict
  116. [mysql] Generates multiple chunks when approximate row count is bigger than chunk size (#1193)
  117. [cdc-base] Fix NPE during snpashot scan phase (#1339)
  118. [docs] Improve MySQL ZH document and update the outdated links (#1435)
  119. [docs] Translate mysql cdc doc to Chinese (#1391)
  120. [mysql] Introduce 'scan.incremental.snapshot.chunk.key-column' option to support splitting table by custom column (#1415)
  121. [mysql] Optimize pure binlog phase check logic to improve performance (#1392)
  122. [oracle] Fix mining session stopped due to 'No more data to read from socket'
  123. [common] Ignore retriableException to make the debezium engine retry works
  124. [test][oracle] Fix unstable tests OracleE2eITCase due to reuse container
  125. [tidb] Fix NPE when the specified table does not exist (#1411)
  126. [docs] Add step up SQLServer Database cdc document in sqlserver-cdc.md.
  127. [mongodb] Expose batch.size config option for table source. (#1387)
  128. [mongodb] Example tests for MongoDBSource (#138...
Read more
Assets 2
Loading

Release-2.2.1

26 Apr 12:42
@PatrickRen PatrickRen
release-2.2.1
bb7a7b8
Compare
Choose a tag to compare
Release-2.2.1

Release Notes

Improvements and Bug fixes

  1. [docs] Update the dependencies version used in docs to 2.2.0
  2. [hotfix][docs] Fix jar link for PolarDB-X docs (#1013)
  3. [docs] Add example for Scan Newly Added tables feature (#1016)
  4. [hotfix][docs] Fix misspell of docs title
  5. [docs][mysql] Add note to make the tableList usage and dependencies clearer (#1037)
  6. [docs] Update the supported sink vendors
  7. [sqlserver] Add more supported(tested) SqlServer versions (#1049)
  8. [oceanbase] Remove useless dependency and code of test (#1046)
  9. [docs][mysql] Fix connector document link error (#1043)
  10. [mysql] Serialize isSuspended flag for MySqlBinlogSplit (#1055)
  11. [common] Apply filter on ResolvedSchema to keep physical columns only (#1097)
  12. [docs][mongodb] Update document about MongoDB database and collection regex filter (#1090)
  13. [mysql] Throw RuntimeException timely in snapshot scan phase (#1099)
  14. [hotfix][tidb] Fix RowKind.INSERT judgement condition (#1104)
  15. [mysql] Catch and hold exception in chunk splitter thread and rethrow in getNext() (#1110)
  16. [mysql] Use the gtid set firstly when compare the binlog offset (#1111)
  17. [mysql] Add heartbeatInterval field to equals() and hashCode() (#1118)

Download

Documentation

Assets 2
Loading

Release-2.2.0

27 Mar 13:28
@leonardBang leonardBang
release-2.2.0
8baf91b
Compare
Choose a tag to compare
Release-2.2.0

Release Notes

Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.2/

Features and Improvements

  1. [docs] Update the supported database vendors and improve the notes.
  2. [docs][mysql][polardbx] Add polardbx tutorials (#1003)
  3. [docs][mysql] Remove redundant docker environment variable in tutorials (#1005)
  4. [cdc-base] Add MySQL Incremental Source to validate the Incremental Snapshot Framework(#776)
  5. [cdc-base] Improve the Incremental Snapshot Interfaces
  6. [cdc-base] The first version of Incremental Snapshot Framework abstraction
  7. [hotfix][docs] Fix markdown title due to typo in readme
  8. [oceanbase] Bump the oblogclient version to 1.0.3 to fix the NPE in oblogclient connection (#998)
  9. [docs] Clarify ownership to comply with ASF trademark policies (#1000)
  10. [build] Decrease the azure job timeout to reasonable 40 minutes (#991)
  11. [hotfix][site] Use Flink with its trademark
  12. [docs] Adopt the full name 'Apache Flink' with its trademark notice (#988)
  13. [hotfix][docs] Update the copyright
  14. [docs][mysql] Correct the jdbc driver version in documentation
  15. [docs] Organize the connector docs in alphabetical order
  16. [docs][tidb] Add tidb cdc connector document
  17. [hotfix][docs] Fix typo in tidb-tutorial.md and tidb-tutorial-zh.md
  18. [mysql] Suspend SourceReader eagerly to reduce restoration time
  19. [docs][oceanbase] Add quickstart tutorials for OceanBase CDC connector
  20. [docs][oceanbase] Add docs for OceanBase CDC connector
  21. [build][oceanbase] Use self-hosted agent for oceanbase cdc tests
  22. [oceanbase] Add OceanBase CDC connector
  23. [tidb] remove useless code.
  24. [test][e2e] Use single fork in tests
  25. [test][e2e] Clean up database resources for every e2e tests.
  26. [e2e] bump flink e2e test version.
  27. [tidb] Add tidb cdc connector e2e test.
  28. [tidb] Add flink1.14 support.
  29. [hotfix][mysql] Avoid schema isn't known error when scanNewlyAddedTable enabled (#965)
  30. [mysql][polardbx] Remove debug print code in PolardbxSourceTCase (#968)
  31. [tidb] Introduce runtime converter to improve the deserialization
  32. [tidb][test] Add timezone tests for tidb
  33. [tidb] Remove useless config options
  34. [docs][site] Add favicon fot website index html
  35. [docs][site] Introduce static index html for the project website (#961)
  36. [mysql] Split snapshot chunks asynchronously (#931)
  37. [docs][tidb] Add index for tidb tutorial docs
  38. [tidb][docs] Add tidb connector tutorial (#938)
  39. [tidb] Add metadata column ITCase and improve the code style
  40. [tidb][test] Fix tikv port conflicts
  41. [tidb] Support metadata column
  42. [tidb][test] Add tidb pipeline in azure CI
  43. [tidb][test] Add TiDBTableSourceFactoryTest and TiDBConnectorITCase
  44. [tidb] Fix tikv.pd.addresses not work and use ResolvedSchema instead of TableSchema.
  45. [tidb] Bump tikv client version to v3.2.0
  46. [tidb] The first draft of tidb cdc connector
  47. [docs] List supported databases in docs (#954)
  48. [mysql] Fallback to build schema by 'desc table' case when parsing DDL failure (#949)
  49. [docs] Fix download url in mongodb tutorial (#951)
  50. [docs] Update DingTalk QR code to English version (#950)
  51. [mongodb] Match multiple database and collection names using a regular expression in MongoDB. (#940)
  52. [mysql] Allow custom JDBC URL parameters in MySQL CDC source (#921)
  53. [mongodb][test] Fix unstable tests of MongoDBConnectorITCase (#944)
  54. [mysql] Improve mysql heartbeat feature and tests
  55. [mysql] Original implementation of mysql heartbeat feature
  56. [common] Update issue templates
  57. [hotfix][mysql] Fix MySqlSourceReader#snapshotState should return unfinishedSplits (#926)
  58. [docs] Fix the outdated link of flink download link (#922)
  59. [hotfix][mysql] Fix the binlog position didn't update when emit DDL (#925)
  60. [mongodb] Correct the TypeInformation argument of DebeziumDeserializationSchema in SourceFuntion (#780)
  61. [common] Allow user to pass custom JsonConverter configs in JsonDebeziumDeserializationSchema (#615)
  62. [mysql] Improve the test to cover table with varbinary primary key (#879)
  63. [mysql] Support primary key with varbinary type (#879)
  64. [format][changelog-json] Remove the support of changelog-json format (#912)
  65. [hotfix][minor] Fix the test code typo
  66. [mysql] Fix ArrayIndexOutOfBoundsException in mysql binlog read phase (#911)
  67. [mongodb][tests] Track MongoDBITCase hang in azure (#881)
  68. [docs] Update the supported flink version mapping (#885)
  69. [common] Fix emitDelay and fetchDelay metrics to be 0L during snapshot phase (#878)
  70. [hotfix][docs][mongodb] Update supported mongodb versions in README.md
  71. [docs][sql-server] Add sqlserver-cdc connector tutorial (#687) This closes #687.
  72. [common] Use ResolvedSchema instead of deprecated TableSchema API (#782)
  73. [docs][sqlserver] Add SqlServer CDC connector document (#705)
  74. [doc][sqlserver] Add SqlServer English tutorial document. (#693)
  75. [common] Make Flink CDC Compatible with Flink 1.14
  76. [build] Bump flink version to 1.13.5
  77. [docs][oracle] Add guidance about oracle CDB database (#792)
  78. [docs] Add connection.pool.size and connect.max-retries option in mysql document (#857)
  79. [sqlserver] Add e2e tests for sqlserver cdc connector (#837)
  80. [hotfix][mysql] Rename method from dispatchHighWatermark to dispatchBinlogEndEvent (#810) This closes #810.
  81. [mysql] Use READ type for all records in snapshot reading (#842)
  82. [mysql] Rewrite the newly added table tests to cover more cases (#777) This closes #777.
  83. [mysql] Improve newly added tables process
  84. [mysql] Support capture newly added tables for existed pipeline
  85. [docs] Fix typo in mongodb-cdc.md (#836)
  86. [mysql] add test to cover the datatype GeomCollection that's synonymous with GeometryCollection for mysql8 (#822)
  87. [sqlserver] Add SqlServer cdc connector (#662)
  88. [build] Remove redundant maven enforce plugin (#794)
  89. [hotfix] Fix MySqlSource comment typo (#793)
  90. [mysql] Support MySQL 5.6 (#396)
  91. [build] Switch to Log4j 2 by default (#791)
  92. [oracle] Fix Oracle numeric types conversion (#560)
  93. [hotfix][mysql] Fix message timestamp of snapshot record to 0L (#752)
  94. [docs] Translate the Chinese FAQ document to English (#737)
  95. [docs] Remove the fixed version of website (#730)
  96. [hotfix][mysql] Set minimum connection pool size to 1 (#692)
  97. [build] Bump log4j2 version to 2.16.0 (#714)
  98. [build] Remove override definition of maven-surefire-plugin in connectors pom (#673)
  99. [docs] Add FAQ for tableList option usage in DataStream API (#634)
  100. [mongodb] Support to connect MongoDB without authentication (#642)
  101. [hotfix] Fix the parameter typo in java doc (#651)
  102. [mysql] Add a method to get MySqlSourceConfigFactory from MySqlSource (#648)
  103. [mysql] Set default driver class name for PooledDataSource (#659)
  104. [mysql] Fix there is duplicate records outputted when keep updating table during snapshot read (#592)
  105. [docs] Improve column name note in oracle cdc document. (#625)
  106. [docs] Add Flink cdc eco-system picture (#623)
  107. [hotfix][docs] Fix typo in oracle-cdc.md (#613)
  108. [docs] Add supported Flink versions for Flink CDC 2.1(#611)
  109. [build] Bump version to 2.2-SNAPSHOT

Download

Contributor List (sorted alphabetically)

  1. Dian Qi
  2. He Wang
  3. Jark Wu
  4. Jiabao Sun
  5. Jingsong Lee
  6. Junwang Zhao
  7. Konstantin Knauf
  8. Leonard Xu
  9. Mustang Kong
  10. Paul Zhang
  11. Qingsheng Ren
  12. Sergey Nuyanzin
  13. Shengkai
  14. Tuple
  15. Xianxun Ye
  16. Xuebing Li
  17. Zongwen Li
  18. camelusluo
  19. eastfisher
  20. ehui
  21. fangpc
  22. gongzhongqiang
  23. hele.kc
  24. hiscat
  25. luoyuxia
  26. paul8263
  27. skylines
  28. szgeqin
  29. taox
  30. tsreaper
  31. wangxiaojing
  32. wysstartgo
  33. yexianxun
  34. ๅ…ƒ็ป„
Assets 2
Loading

Release-2.1.1

17 Dec 07:15
@leonardBang leonardBang
release-2.1.1
c64482d
Compare
Choose a tag to compare
Release-2.1.1

Release Notes

Improvements and Bug fixes

  1. [docs] Remove the fixed version of website (#730)
  2. [hotfix][mysql] Set minimum connection pool size to 1 (#692)
  3. [build] Bump log4j2 version to 2.16.0 (#714) Note: This project only uses log4j2 in test code and won't be influenced by log4shell vulnerability
  4. [build] Remove override definition of maven-surefire-plugin in connectors pom (#673)
  5. [docs] Add FAQ for tableList option usage in DataStream API (#634)
  6. [mongodb] Support to connect MongoDB without authentication (#642)
  7. [hotfix] Fix the parameter typo in java doc (#651)
  8. [mysql] Set default driver class name for PooledDataSource (#659) (#661)
  9. [mysql] Fix there is duplicate records outputted when keep updating table during snapshot read (#592)
  10. [docs] Improve column name note in oracle cdc document (#633)
  11. [docs] Add Flink cdc eco-system picture (#624)
  12. [hotfix][docs] Fix typo in oracle-cdc.md(#616)
  13. [docs] Add supported Flink versions for Flink CDC 2.1(#608)

Download

Documentation

Assets 2
Loading

Release-2.1.0

15 Nov 07:15
@leonardBang leonardBang
release-2.1.0
670c964
Compare
Choose a tag to compare
Release-2.1.0

Release Notes

Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.1/

Features and Improvements

  1. [tests] Add end-to-end tests for cdc connector uber jars (#594)
  2. [tests] Upgrade testcontainers dependency to 1.16.2 (#591)
  3. [mysql] Reading a null column with default value defined should return null instead of default value (#555)
  4. [mysql] Optimize the dynamic chunk size calculation for table with dense distribution (#599)
  5. [mongodb] Fix MongoDBConnectorITCase is timeout on Azure (#600)
  6. [hotfix][mysql] Fix number overflow in ObjectUtils.minus (#598)
  7. [mongodb] Fix problem of cannot look up fields on non-struct type (#588)
  8. [hotfix][mongodb] Fix NullPointException when heartbeat option is enabled (#586)
  9. [postgres] Support 'schema-name' metadata column for postgres-cdc connector
  10. [oracle] Support metadata columns for oracle connector
  11. [tests] Split the CI pipeline into multiple stages for better performance (#572)
  12. [hotfix][mongodb] Correct the connection uri building of MongoDB (#568)
  13. [mysql] Skip ddl events in snapshot split normalization (#577)
  14. [mysql] Support dynamic chunk size for evenly distribution table
  15. [mysql][minor] Use 'table.include.list' key instead of legacy key 'table.whitelist' in SnapshotSplitReader
  16. [mysql] Set server time zone information for connection pool factory (#566)
  17. [mysql] Polish binlog offset compare semantic (#543)
  18. [build] Update NOTICE file for sql connector jar (#565)
  19. [postgres] Support metadata columns for postgres-cdc connector (#500)
  20. [debezium] Bump up debezium version to 1.5.4.Final (#554)
  21. [oracle] Shade dependencies for oracle-cdc connector (#519)
  22. [hotfix][docs] Fix the display of github star button
  23. [common] Fix NPE of JsonConverter when job run on cluster(#470)
  24. [mongodb] Support metadata columns for mongodb-cdc connector (#476)
  25. [mysql] Reduce the connection usage in table discovery process
  26. [build] bump maven shade plugin version to 3.2.4
  27. [mysql] Introduce Jdbc connection pools
  28. [mysql] support all mysql data types (#438)
  29. [hotfix][docs] Correct the Kibana link in Oracle connector documentation (#539)
  30. [mysql] Support binlog split with huge snapshot split meta
  31. [mysql] Support tables with different split key
  32. [mysql] Validate the regex pattern of database-name and table-name in table factory (#526)
  33. [build] Add necessary shaded dependencies (#512)
  34. [oracle][test] Fix oracle tests failure in azure due to ORA-01882
  35. [oracle][minor] Fix checkstyle and typo
  36. [oracle] Add docker build 'on-the-fly' and refactor test image
  37. [oracle] Added validator for oracle
  38. [oracle] Updated package naming to com.ververica in oracle connector
  39. [oracle] Fixing unit tests, cleaning up after adding oracle cdc
  40. [oracle] Add oracle cdc connector
  41. [build] Upgrade azure environment from ubuntu-16.04 to ubuntu-18.04 (#517)
  42. [hotfix][mysql] Correct the usage of includeSchemaChanges parameter (#501)
  43. [build] Follow Flink builtin connector shade style (#49)
  44. [mysql] Expose MySqlSource API that supports incremental snapshot (#495)
  45. [mysql] Support metadata columns for mysql-cdc connector (#496)
  46. [common] Support to read tables of inconsistent schema (#494)
  47. [build] Fix maven connection timeout issue in azure CI
  48. [mysql] Support wide table with huge number of columns
  49. [tests] Correct the argument order of assertArrayEqualInOrder/assertArrayEqualAnyOrder
  50. [tests] Introduce assertEqualsInOrder/assertEqualsInAnyOrder methods for test
  51. [tests] Improve the unstable test testStartupFromLatestOffset in MySqlConnectorITCase
  52. [mysql] Fix the restoration failure when checkpoint happened in one MySQL transaction
  53. [mysql] Optimization that skips the binlog read if the low watermark equals high watermark
  54. [mysql] Add source metrics for MySqlParallelSource
  55. [build] Use tools with stable version in building docs
  56. [mysql] Use min/max of split key and row count to describe the distribution of table
  57. [mysql] Fix the ClassCastException in RecordUtils
  58. [mongodb][docs] Add documentation for mongodb-cdc connector (#395)
  59. [mongodb] Remove no need config option prefix 'debezium.' (#420)
  60. [mongodb] Support MongoDB CDC connector (#225)
  61. [common] Shade kafka-related dependency (#386)
  62. [common] Support json deserialization schema
  63. [mysql] Improve the tests code
  64. [mysql] Fix the MySqlSnapshotSplitAssigner may assign duplicate splits
  65. [mysql] Add tests to check mysql-cdc works well under various timezones (#367)
  66. [mysql] Optimize the checkpoint be optional under single parallelism (#365)
  67. [postgres] Fix postgres-cdc connector cannot recognize the optional option 'slot.name'
  68. [mysql] Correct the initial binlog offset for MySqlHybridSplitAssigner
  69. [mysql] Add default value for 'database.history.instance.name' in MySqlParallelSource
  70. [common] Remove useless parameter 'converter.schemas.enable'
  71. [build] Run integration tests for each building
  72. [mysql] Improve the code format in SignalEventDispatcher
  73. [postgres] Fix Validator didn't implement Serializable
  74. [changelog] fix changelog-deserialize exception message typo.
  75. [build] Update issue templates
  76. [docs] Add tutorial about building real-time data lake for MySQL sharding table with Flink CDC (#551)
  77. [docs] Add metadata column example for mysql-cdc and mongodb-cdc connector
  78. [docs] Add checkpoint configuration limitation for Oracle and Postgres connector (#580)
  79. [docs] Fix the link of 'edit on github' on site (#578)
  80. [docs] Use SNAPSHOT version dependency in master documentation (#497)
  81. [docs] Use more generic term 'transaction logs' in README
  82. [docs] Add MySQL HA cluster support explanation
  83. [docs] Update the dependency version to 2.1.0
  84. [docs] Add checkpoint configuration limitation for Oracle and Postgres connector
  85. [docs] Fix the link of 'edit on github' on site (#578)
  86. [docs][oracle] Fix oracle DATE type mapping in documentation (#569)
  87. [docs] Translate "Streaming ETL for MySQL and Postgres with Flink CDC" into Chinese (#550)
  88. [docs] Add GitHub star button to documentation (#547)
  89. [docs] Add Oracle support in README
  90. [docs] Restructure the "tutorials" to "quickstart"
  91. [docs] Add documentation for oracle-cdc (#515)
  92. [docs] Rewrite tutorial doc for mysql-postgres-tutorial (#514)
  93. [docs] Add favicon for docs website (#525)
  94. [docs] Use new MySqlSource API in documentation
  95. [docs] Correct DataStream API usage in document examples
  96. [docs] Use JsonDeserializationSchema as output format in examples
  97. [docs] Update documentation of tutorial
  98. [docs] Add meaningful title for tutorial
  99. [docs] Support build document website locally
  100. [docs] Fix the broken link in readme
  101. [docs] Update the debezium document link to version 1.5
  102. [docs][mysql] Fix LowerCase Class name typo
  103. [docs] Add checkpoint config in document example
  104. [docs] Add FAQ for MySQL 8.0 Public Key Retrieval setting
  105. [docs] Add checkpoint and primary key setting for example in tutorials
  106. [docs] Fix the imports in document demo
  107. [docs] Set the content width of the website
  108. [docs] Update DingTalk group picture size in README.md
  109. [docs] Update the supported connector version and link

Download

Contributor list

Gunnar Morling, Jark Wu, Jiabao Sun, Leonard Xu, MartijnVisser, Marton Balassi, Shengkai, Tamas Kiss, Tamas Zseder, Zongwen Li, dongdongking008, frey66, gongzhongqiang, ili zh, jpatel, lsy, luoyuxia, manmao, mincwang, taox, tuple, wangminchao, yangbin09

Assets 2
Loading

Release 2.0.2

23 Sep 13:28
@leonardBang leonardBang
release-2.0.2
7ba9c5c
Compare
Choose a tag to compare
Release 2.0.2

Release Notes

Improvements and Bug fixes

  1. [mysql] Fix the MySqlSnapshotSplitAssigner may assign duplicate splits
  2. [mysql] Fix the restoration failure when checkpoint happened in one MySQL transaction
  3. [mysql] Fix the ClassCastException in RecordUtils
  4. [mysql] Optimization that skips the binlog read if the low watermark equals high watermark
  5. [mysql] Support wide table with huge number of columns
  6. [mysql] Use min/max of split key and row count to describe the distribution of table
  7. [mysql] Add source metrics for MySqlParallelSource
  8. [tests] Correct the argument order of assertArrayEqualInOrder/assertArrayEqualAnyOrder
  9. [tests] Introduce assertEqualsInOrder/assertEqualsInAnyOrder methods for test
  10. [tests] Improve the unstable test testStartupFromLatestOffset in MySqlConnectorITCase
  11. [docs] Fix the broken link in readme
  12. [docs] Correct DataStream API usage in document examples
  13. [docs] Support build document website locally
  14. [docs] Update documentation of tutorials
  15. [docs] Add meaningful title for tutorials
  16. [build] Use tools with stable version in building docs
  17. [build] Fix maven connection timeout issue in azure CI

Download

Documentation

Assets 2
Loading

Release 2.0.1

27 Aug 11:38
@leonardBang leonardBang
release-2.0.1
eef05b1
Compare
Choose a tag to compare
Release 2.0.1

Release Notes

Improvements and Bug

  1. [postgres] Fix Validator didn't implement Serializable
  2. [mysql] Correct the initial binlog offset for MySqlHybridSplitAssigner
  3. [mysql] Optimize the checkpoint be optional under single parallelism
  4. [postgres] Fix postgres-cdc connector cannot recognize the optional option 'slot.name'
  5. [mysql] Improve the code format in SignalEventDispatcher
  6. [mysql] Add default value for 'database.history.instance.name' in MySqlParallelSource
  7. [mysql] Add tests to check mysql-cdc works well under various timezones
  8. [common] Remove useless parameter 'converter.schemas.enable'
  9. [build] Run integration tests for each building
  10. [changelog] fix changelog-deserialize exception message typo
  11. [docs] Add FAQ for MySQL 8.0 Public Key Retrieval setting
  12. [docs] Update the debezium document link to version 1.5
  13. [docs] Add checkpoint and primary key setting for example in tutorials

Download

Documentation

Assets 2
Loading

Release 2.0.0

11 Aug 07:31
@leonardBang leonardBang
release-2.0.0
7541eeb
Compare
Choose a tag to compare
Release 2.0.0

Release Notes

Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.0/

Features and Improvements

  1. [mysql] Support MySQL-CDC 2.0 which offers parallel reading, lock-free and checkpoint feature
  2. [mysql] Enable single server id for MySqlParallelSource
  3. [mysql] Keep the global order of between snapshot records and binlog records
  4. [mysql] Support binlog reader merge optimization
  5. [mysql] Support numeric type optimization for split boundary calculation
  6. [mysql] Support table with combined primary key
  7. [mysql] Support latest-offset mode for MySqlParallelSource
  8. [build] Rename group.id and package name from 'com.alibaba.ververica' to 'com.ververica'
  9. [build] Bump flink version to 1.13.1
  10. [mysql] Forbid using problematic startup options earliest-offset/specific-offset/timestamp
  11. [mysql] Validate MySQL server configuration (version, binlog_format, binlog_row_image) before start job
  12. [mysql] Refactor class names to use 'MySql' prefix instead of 'MySQL'
  13. [common] Avoid uncompleted state of schema history when engine stop before checkpoint
  14. [common] Fix schema history run out of memory
  15. [common] Fix ClassCastException in type conversion
  16. [docs] Use sphinx-rtd-theme to manage project documents
  17. [docs] Support versioned documents with RTD(ReadTheDocs)

Upgrade Notes

Please note the following incompatible changes when you're upgrading your existed Flink CDC project.

  • The group.id and package name of Flink CDC has renamed from 'com.alibaba.ververica' to 'com.ververica' for making the project
    more neutral
  • The problematic startup options earliest-offset/specific-offset/timestamp has been disabled until they're correctly supported
  • The class name prefix has changed from 'MySQL' to 'MySql' for better code style.

Download

Assets 2
Loading

Release 1.4.0

12 May 04:22
@leonardBang leonardBang
release-1.4.0
ff2db62
Compare
Choose a tag to compare
Release 1.4.0

Release Notes

Documentation: https://ververica.github.io/flink-cdc-connectors/release-1.4/

Features and Improvements

  1. [debezium] Bump Flink version to 1.13.0

Download

Assets 2
Loading

Release 1.3.0

29 Mar 11:41
@wuchong wuchong
release-1.3.0
29bfc3b
This commit was signed with the committerโ€™s verified signature.
wuchong Jark Wu
GPG key ID: 85BACB5AEFAE3202
Verified
Learn about vigilant mode.
Compare
Choose a tag to compare
Release 1.3.0

Release Notes

  1. [postgres] Flush LSN offset to PG even if no updates to the monitored tables to avoid infinite WAL segments (#111)
  2. [mysql] Fix NPE when the application started for the first time and captured a empty table (#119)
  3. [debezium] Add source metrics according to FLIP-33

Download

Assets 2
Loading