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

2021-03-30 文章 Robin Zhang
Hi,air23 JDBCTableSource就是batch模式的,不走实时。Flink解析执行计划时内部会去判断。 Best air23 wrote > 这边是想离线读取。不是走实时的 > 看到异常是 Only insert statement is supported now > > > > > > > > > > > > > > > > > > 在 2021-03-30 10:31:51,"guoyb" < > 861277329@ >> 写道: >>可以读取的,还有内置flink cdc

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

2021-03-29 文章 air23
这边是想离线读取。不是走实时的 看到异常是 Only insert statement is supported now 在 2021-03-30 10:31:51,"guoyb" <861277...@qq.com> 写道: >可以读取的,还有内置flink cdc >select得用query方法,看看是不是用错了execute。 > > > >---原始邮件--- >发件人: "air23"发送时间: 2021年3月30日(周二) 上午10:25 >收件人: "user-zh"主题: flink 从mysql读取数据异常 > > >你好 参考官网

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

2021-03-29 文章 guoyb
可以读取的,还有内置flink cdc select得用query方法,看看是不是用错了execute。 ---原始邮件--- 发件人: "air23"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