❶ flink1.7.2 升级1.13.6问题集
根据经验flink on yarn在config.sh 配置 hadoop classpath 并没有完全加载hadooo classpath中所有的环境变量的jar包,避坑:不要在项目中引用hadoop 环境变量中的jar包,为idea调试用,可以配置scope provided
flink org.apache.logging.log4j.spi.LoggerContextFactory.isClassLoaderDependent()Z 报错
flink on yarn .NoClassDefFoundError: Could not initialize class org.apache.logging.log4j.core.LoggerContext
背景flink1.13 on yarn datastream scala项目
背景 flink 1.7.2 datastream scala项目 添加参数 flink-conf.yaml ,因为源码对这部分改动很大,可以选择flink到1.13.6,自动修复上诉问题
yqu etl 发现不生效了
后续指定flink运行参数,建议使用-Dxx=xx
使用 -Dyarn.application.queue=etl