https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q
????pyflink??jdbc??jar??jdbc??flink??1.13.1
> >
> >
> >
> > from pyflink.datastream import StreamExecutionEnviro
> 发送时间: 2021年6月1日(星期二) 下午5:30
> 收件人: "user-zh"
> 主题: 回复： Pyflink jdbc相关
>
>
>
>
>
> 感谢，我换成2.11确实可以了
>
>
> -- 原始邮件 --
> 发件人:
;
??
-- --
??:
""
<1129656...@qq.com>;
: 2021??6??1??(??) 5:30
??: "user-zh"https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q
pyflink
er-zh"
https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q
????pyflink??jdbc??jar??jdbc??flink??1.13.1
>
>
>
> from pyflink.datastream import StreamExecutionEnvironment
> from pyflink.table impo
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
> 试着使用pyflink，遇到了问题，
Hi??
??https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q
pyflink??jdbc??jar??jdbc??flink??1.13.1
from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment
