@许诺 把flink-conf.yaml 里面的ha配置去掉

吉野家

@Josiah 不用做判断，你自己试一下放任何执行语句都可以

只有中间那个条件判断可以控制循环语句，其它的都只是执行

@CM 最好环境始终如一，要么就都是py2，要么就都是py3。你自己也可以挑战py3，当然按照老师的步骤弄可以少踩一些坑。

开发工具中，不同的py脚本指定不同的py虚拟机呗，开发环境可以玩一下，部署环境应该实现不了

@AIZero 我觉得还是你的程序哪里出错了然后任务自己退出了

第一个包冲突了，自己慢慢排查，应该还是scala版本的问题。第二个为啥是cancel任务了？

小伙真的很努力，以后指定有发展

还有group by。子查询。常见的udf函数比如字符串拼接，字符串分割，集合获取，日期处理，条件判断if或case when等。udaf函数max，count，sum等。udtf函数。还有窗口函数rownumber。还有行转列和列转行的操作。

各种join能流畅使用，还有常见的函数也会用

你的磁盘权限问题

啥意思？