Re:回复：flink 从mysql读取数据异常

Mon, 29 Mar 2021 22:30:03 -0700 

这边是想离线读取。不是走实时的 
看到异常是 Only insert statement is supported now

















在 2021-03-30 10:31:51，"guoyb" <861277...@qq.com> 写道：
>可以读取的，还有内置flink cdc
>select得用query方法，看看是不是用错了execute。
>
>
>
>---原始邮件---
>发件人: "air23"<wangfei23_...@163.com&gt;
>发送时间: 2021年3月30日(周二) 上午10:25
>收件人: "user-zh"<user-zh@flink.apache.org&gt;;
>主题: flink 从mysql读取数据异常
>
>
>你好 参考官网 
>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&nbsp; a = "-- register a MySQL table 'users' in Flink SQL\n" +
>"CREATE TABLE MyUserTable (\n" +
>"&nbsp; id BIGINT\n" +
>") WITH (\n" +
>"&nbsp;&nbsp; 'connector' = 'jdbc',\n" +
>"&nbsp;&nbsp; 'url' = 'jdbc:mysql://***:3306/monitor',\n" +
>"&nbsp;&nbsp; 'table-name' = 't1',\n" +
>"&nbsp;&nbsp; 'username' = 'root',\n" +
>"&nbsp;&nbsp; 'password' = '***'\n" +
>") ";
>
>String b ="-- scan data from the JDBC table\n" +
>"SELECT id FROM MyUserTable\n";
>
>tEnv.executeSql(a);
>
>
>
>请问是不可以从mysql读取数据吗？

回复