https://mp.weixin.qq.com/s/GyFTjQl6ch8jc733mpCP7Q
????pyflink??jdbc??jar??jdbc??flink??1.13.1
gt;
gt;
gt;
gt; from pyflink.datastream import StreamExecutionEnvironment
gt; from pyflink.table import StreamTableE
gt; 发送时间: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 import StreamTableE
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
>
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
