Re: flink sql 连接mysql 无数据输出

2020-11-25 文章 Kyle Zhang
上面写错了,table要转成stream再打印 On Thu, Nov 26, 2020 at 11:46 AM Kyle Zhang wrote: > 调用executeSql,应该输出到另一张表里,比如printTable才能打印。 > 要不就是bsTableEnv.sqlQuery("select * from meson_budget_data").print()打印出来; > > On Thu, Nov 26, 2020 at 9:54 AM Leonard Xu wrote: > >> Hi >> >> 调用了executeSql,作业就已经执行了,不用再调用下面的这个执

Re: flink sql 连接mysql 无数据输出

2020-11-25 文章 Kyle Zhang
调用executeSql,应该输出到另一张表里,比如printTable才能打印。 要不就是bsTableEnv.sqlQuery("select * from meson_budget_data").print()打印出来; On Thu, Nov 26, 2020 at 9:54 AM Leonard Xu wrote: > Hi > > 调用了executeSql,作业就已经执行了,不用再调用下面的这个执行方法,看你已经配置了cp,确认下mysql的参数是否正确。 > > > 在 2020年11月25日,18:42,冯草纸 写道: > > > > env.execute("sq

Re: flink sql 连接mysql 无数据输出

2020-11-25 文章 Leonard Xu
Hi 调用了executeSql,作业就已经执行了,不用再调用下面的这个执行方法,看你已经配置了cp,确认下mysql的参数是否正确。 > 在 2020年11月25日,18:42,冯草纸 写道: > > env.execute("sql test"); > // bsTableEnv.execute("sql test");

Re: flink sql 连接mysql 无数据输出

2020-11-25 文章 caozhen
是不是没有加这一行代码,tableEnv.execute("test"); AlfredFeng wrote > Hi All, >     我在Idea里用flink-jdbc-connector连接mysql, > 建完表后执行env.executeSql("select * from my_table").print()方法,只打印了表头,没有数据是什么原因? > flink版本1.11.2 -- Sent from: http://apache-flink.147419.n8.nabble.com/