flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[mysql] Don't support MySQL type 'INT UNSIGNED ZEROFILL' yet.

Open yd0906 opened this issue 3 years ago • 1 comments

Describe the bug(Please use English) A clear and concise description of what the bug is.

Environment :

  • Flink version : 1.13.3
  • Flink CDC version: 2.2.1
  • Database and version: mysql5.6

To Reproduce Steps to reproduce the behavior:

  1. The test data :
  2. The test code :
  3. The error : Don't support MySQL type 'INT UNSIGNED ZEROFILL' yet.

Additional Description If applicable, add screenshots to help explain your problem. Caused by: java.lang.UnsupportedOperationException: Don't support MySQL type 'INT UNSIGNED ZEROFILL' yet. at com.ververica.cdc.connectors.mysql.schema.MySqlTypeUtils.convertFromColumn(MySqlTypeUtils.java:131) at com.ververica.cdc.connectors.mysql.schema.MySqlTypeUtils.fromDbzColumn(MySqlTypeUtils.java:72) at com.ververica.cdc.connectors.mysql.source.assigners.ChunkSplitter.isEvenlySplitColumn(ChunkSplitter.java:272) at com.ververica.cdc.connectors.mysql.source.assigners.ChunkSplitter.splitTableIntoChunks(ChunkSplitter.java:143) at com.ververica.cdc.connectors.mysql.source.assigners.ChunkSplitter.generateSplits(ChunkSplitter.java:85)

yd0906 avatar Aug 10 '22 02:08 yd0906

Could you please provide a test about this? This type test should already be contained in MySqlConnectorITCase#testMysql57AllDataTypes.

ruanhang1993 avatar Aug 10 '22 02:08 ruanhang1993

Hi @yd0906, this problem seems to be fixed by #1197 and will be released in the next version. You can use the master branch to package it yourself, or patch it from that commit.

Jiabao-Sun avatar Aug 16 '22 02:08 Jiabao-Sun