kalencaya commented on issue #1428: URL: https://github.com/apache/incubator-seatunnel/issues/1428#issuecomment-1063570066
> 我也碰到类似这个问题，有两个情况出现了预期外的情况，V2.0.4版本： 1.运行报空指针，原因是因为mysql里面有些字段是tinyint类型，没有匹配上 2.分别测试了mysql和5.6，8.0版本，5.6版本有一些列名大小写相关问题，8.0版本没法获取到columns定义(可能是JDBC驱动问题)，导致io.github.interestinglab.waterdrop.flink.source.JdbcSource.java的getRowTypeInfo方法中names数组元素为空。 > > 还有个问题，目前的正则匹配“select (.+) from (.+).*” 没法匹配带where条件的语句，在一些需要使用预筛选的情况暂时没法实现。 I had also tested PostgreSQL，which differs more with mysql column type and more NPE caused `JdbcSource#getRowTypeInfo` absence of mapping. Some popular data integration tools based on flink try to split flink-connector-jdbc to concrete RDBMS plugin such as flink-connector-jdbc-mysql for different sql dialect. Another problem is that Table level api can't support some field type produced by MySQL connector. Reproduction process is that you can define a MySQL table with `bigint unsigned` column type, then `ResultSet` implemented by MySQL connector would return `BigInteger` java type for that column, some exception followes. -- 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]
