240 发简信
IP属地:山东
  • 大佬您好,我按照您的方法修改了,也重新编译了源码,flink1.11.2,替换了cluster里面的jar包,发现用yarn-session方式可自定义jobname的,用per-job模式提交,还是insert+*****那种,不太明白问题出在哪里

    解决Flink1.11.0不能指定SQL任务JobName问题

    前言: Flink最近刚发布了1.11.0版本,由于加了很多新的功能,对sql的支持更加全面,我就迫不及待的在本地运行了个demo,但是运行的时候报错了: 虽然报错,但任务却...