❶ 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