如何在 flink 应用程序中使用 Log4j 2

How to use Log4j 2 with flink application

正如我在下面做的那样

 <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-core</artifactId>
        <version>${log4j2.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api</artifactId>
        <version>${log4j2.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api-scala_2.11</artifactId>
        <version>11.0</version>
    </dependency>

在Flink应用中使用log4j2是不行的

log4j2-slf4j 绑定 log4j-slf4j-impl-2。3.jar 将调用从 slf4j 路由到 log4j2。所以添加:

<dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-slf4j-impl</artifactId>
        <version>${log4j2.version}</version>
</dependency>