BenJFan commented on issue #1428: URL: https://github.com/apache/incubator-seatunnel/issues/1428#issuecomment-1063797628
The problem is: Mysql jdbc will return java type `BigInteger` when get `bigint unsigned` is database, check out [there](https://dev.mysql.com/doc/connector-j/8.0/en/connector-j-reference-type-conversions.html). But JdbcSource informationMapping Map convert it to `BIG_INT_TYPE_INFO` which flink not support, check out : [Fix reading BIGINT UNSIGNED type field not work in JDBC](https://issues.apache.org/jira/browse/FLINK-17657?jql=project%20%3D%20FLINK%20AND%20text%20~%20%22sql%20biginter%22#). Also `bigint unsigned` is only in Mysql series database. #### Solve Plan 1. Override JdbcInputFormat so it can hand with `bigint unsigned` as string. 2. Support PostgreSQL's datatype. 3. Separate JdbcSource informationMapping for different databases -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
