We have some customized log4j layout implementation so we need flink job manager/task manager be able to load the logger implementation which is packaged in the uber jar.
However, we noticed that in flink 1.3, the user jar is put at the beginning of job manager, when we do the same again in flink 1.5, the user jar is not there any more. Is this expected? I saw this is the document: *When submitting a Flink job/application directly to YARN (via bin/flink run -m yarn-cluster ...), dedicated TaskManagers and JobManagers are started for that job. Those JVMs have both Flink framework classes and user code classes in the Java classpath. That means that there is no dynamic classloading involved in that case.* And we are using flink on yarn with per-job mode. So confused by what we experiencing for now. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
