conjunto de problemas de actualización 1.13.6 de flink1.7.2

Según la experiencia, flink on Yarn no carga completamente todas las variables de entorno en el paquete jar en el classpath de hadoop cuando config.sh configura el classpath de hadoop. Para evitar trampas: no haga referencia a las variables de entorno de hadoop en el proyecto y utilícelas en. el paquete jar para depuración. Puede configurar el alcance proporcionado

flink org.apache.logging.log4j.spi.LoggerContextFactory.isClassLoaderDependent()Z error

flink on Yarn .NoClassDefFoundError: No se pudo inicializar la clase org.apache .logging.log4j.core.LoggerContext

Backend flink1.13 en el proyecto Yarn Datastream Scala

Backend Flink 1.7.2 en el proyecto Yarn Datastream Scala agregar parámetros flink-conf.yaml porque esta parte del código fuente ha cambiado mucho. Puede elegir flink a 1.13.6 para solucionar automáticamente el problema de apelación

yqu etl descubrió que no tiene efecto

Al especificar los parámetros de tiempo de ejecución de parpadeo más adelante, se recomienda usar - Dxx=xx

Usar -Dyarn.application.queue=etl