flink 从mysql读取数据异常

Mon, 29 Mar 2021 19:32:30 -0700 

你好 参考官网 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/jdbc.html
这边读取mysql jdbc数据报错Exception in thread "main" 
org.apache.flink.table.api.TableException: Only insert statement is supported 
now.


String  a = "-- register a MySQL table 'users' in Flink SQL\n" +
"CREATE TABLE MyUserTable (\n" +
"  id BIGINT\n" +
") WITH (\n" +
"   'connector' = 'jdbc',\n" +
"   'url' = 'jdbc:mysql://***:3306/monitor',\n" +
"   'table-name' = 't1',\n" +
"   'username' = 'root',\n" +
"   'password' = '***'\n" +
") ";

String b ="-- scan data from the JDBC table\n" +
"SELECT id FROM MyUserTable\n";

tEnv.executeSql(a);



请问是不可以从mysql读取数据吗？

回复