[ https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628222#comment-17628222 ]
Hang HOU edited comment on FLINK-29558 at 11/3/22 10:17 AM: ------------------------------------------------------------ I tried flink 1.16.0 with the same env,now in sql-client can swiftly get the exception:"[ERROR] Could not execute SQL statement. Reason: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'FROM `users1013a`' at line 1" ,then the collect job just failed and never retry !image-2022-11-03-18-16-12-127.png! was (Author: JIRAUSER289640): I tried flink 1.16.0 with the same env,now in sql-client can swiftly get the exception:"[ERROR] Could not execute SQL statement. Reason: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'FROM `users1013a`' at line 1" ,then the collect job just failed and never retry > Use select count(*) from xxx; and get SQL syntax > ------------------------------------------------ > > Key: FLINK-29558 > URL: https://issues.apache.org/jira/browse/FLINK-29558 > Project: Flink > Issue Type: Bug > Components: Connectors / JDBC > Affects Versions: 1.15.2 > Environment: flink 1.15.2 > CentOS Linux release 7.9.2009 (Core) > 5.7.32-log MySQL Community Server (GPL) > Reporter: Hang HOU > Priority: Major > Attachments: image-2022-10-10-15-31-34-341.png, > image-2022-10-19-17-55-14-700.png, image-2022-11-03-18-16-12-127.png, > screenshot-1.png, screenshot-2.png > > > Hi, I use flink sql to make kafka records to mysql. > so I create these 2 tables in flink sql,here is the mysql ,and I created the > table in mysql before I did the insert action in flink sql. > CREATE TABLE mysql_MyUserTable ( > id STRING, > name STRING, > age STRING, > status STRING, > PRIMARY KEY (id) NOT ENFORCED > ) WITH ( > 'connector' = 'jdbc', > 'url' = 'jdbc:mysql://10.19.29.170:3306/fromflink152', > 'table-name' = 'users', > 'username' = 'root', > 'password' = '******' > ); > In mysql, I created database "fromflink152" then created the table like this > way > CREATE TABLE `users` ( > `id` varchar(64) NOT NULL DEFAULT '', > `name` varchar(255) DEFAULT NULL, > `age` varchar(255) DEFAULT NULL, > `status` varchar(255) DEFAULT NULL, > PRIMARY KEY (`id`) > ) > After executed insert sql,I found 'select * from mysql_MyUserTable' can get > correct result,but ’select count(\*) from mysql_MyUserTable‘ or ’select > count(id) from mysql_MyUserTable‘ ,the collect job in flink app keep > restarting again and again.The exception is: > !image-2022-10-10-15-31-34-341.png! > So I wonder which config that I missed about the table in flink or mysql side > :( -- This message was sent by Atlassian Jira (v8.20.10#820010)