Re: Pyflink jdbc相关

2021-06-01 文章 Dian Fu
gt; 发送时间:2021年6月1日(星期二) 下午5:30 > 收件人:"user-zh" > 主题:回复: Pyflink jdbc相关 > > > > > > 感谢,我换成2.11确实可以了 > > > -- 原始邮件 -- > 发件人:

Re: Pyflink jdbc相关

2021-06-01 文章 Dian Fu
Hi, 本地执行: 1)用flink-connector-jdbc_2.11-1.13.1.jar试试?因为PyFlink里默认待的JAR包是scala 2.11的 flink run: 1) 你注册的sink表的名字为“print”,不是”table_sink”,但是在SQL语句里用的table_sink。 > 2021年6月1日 下午4:33,琴师 <1129656...@qq.com> 写道: > > Hi, > 我按着微信分享https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q >