赞
踩
问题背景参考:【Flink】Flink 1.13版本升级到Flink 1.17版本
我是从Flink 1.13版本升级到Flink 1.17版本,因为flink 1.13版本是好的,各种任务都能运行,本次升级主要是包的问题,最主要的是Flink去掉了很多scala的依赖。
可以看到从1.15版本开始去掉scala依赖的,本次升级大问题没有多少的。
但是运行任务报错: No ExecutorFactory found to execute the application
根据报错找到报错位置
@Override
public PipelineExecutorFactory
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。