[FLINK-22042] Fix reading bigint(20) UNSIGNED type field cannot be cast

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.12.0, 1.12.2
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Flags: Patch
• Assignee: Unassigned
• Reporter: jingzi
• Created: 30/Mar/21 10:14
• Updated: 23/Sep/21 17:55
• Resolved: 30/Mar/21 10:59

Description

I use flink-clinet read mysql table,but run failed 

Caused by: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long

 

mysql table:

`

CREATE TABLE `testlxone` (
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',

PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC 

`

mysql data

`

1

2

3

`

code:

`

val create ="create table testOne(\n id DECIMAL(20,0)\n)WITH (\n 'connector.type' = 'jdbc',\n 'connector.url' = 'jdbc:mysql://localhost:3306/flink_db?characterEncoding=UTF-8&useSSL=false',\n 'connector.table' = 'testlxone',\n 'connector.username' = 'root',\n 'connector.password' = '123456', \n 'connector.write.flush.max-rows' = '1' \n)"
System.out.println(create)

val create2 ="create table testTwo(\n id DECIMAL(20,0)\n)WITH (\n 'connector.type' = 'jdbc',\n 'connector.url' = 'jdbc:mysql://localhost:3306/flink_db?characterEncoding=UTF-8&useSSL=false',\n 'connector.table' = 'testlxone',\n 'connector.username' = 'root',\n 'connector.password' = '123456', \n 'connector.write.flush.max-rows' = '1' \n)"

val query = "INSERT INTO testTwo select * from testOne"

 

bsTableEnv.executeSql(create)

bsTableEnv.executeSql(create2)

bsTableEnv.executeSql(query)

`

 

 

Issue Links

• links to: GitHub Pull Request #15431