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

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