flink-1.13.6提交sql到远程集群终于成功了

java:1.8

flink-1.13.6-bin-scala_2.11

hive:1.1.1

hadoop:2.6.0-cdh5.16.2

通过纯SQL的流模式提交到远程flink集群执行,中间遇到不少问题,现在终于能跑通了,附码云地址

https://gitee.com/shenxiang2020/flink-study.git