[flink] branch release-1.14 updated: [FLINK-25326][connectors/kafka] Fix application of log levels in KafaUtils.createKafkacontainer

[fpaul]

This is an automated email from the ASF dual-hosted git repository.

fpaul pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new 311fa53  [FLINK-25326][connectors/kafka] Fix application of log levels 
in KafaUtils.createKafkacontainer
311fa53 is described below

commit 311fa53631bcc14c1f279ad123664e4b10c88fc7
Author: Alexander Preuß <11444089+alp...@users.noreply.github.com>
AuthorDate: Thu Dec 16 10:08:48 2021 +0100

    [FLINK-25326][connectors/kafka] Fix application of log levels in 
KafaUtils.createKafkacontainer
---
 .../java/org/apache/flink/connector/kafka/sink/KafkaUtil.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
index 2e37d91..a5c6097 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
@@ -56,16 +56,16 @@ public class KafkaUtil {
      */
     public static KafkaContainer createKafkaContainer(String 
dockerImageVersion, Logger logger) {
         String logLevel;
-        if (logger.isErrorEnabled()) {
-            logLevel = "ERROR";
-        } else if (logger.isTraceEnabled()) {
+        if (logger.isTraceEnabled()) {
             logLevel = "TRACE";
         } else if (logger.isDebugEnabled()) {
             logLevel = "DEBUG";
-        } else if (logger.isWarnEnabled()) {
-            logLevel = "WARN";
         } else if (logger.isInfoEnabled()) {
             logLevel = "INFO";
+        } else if (logger.isWarnEnabled()) {
+            logLevel = "WARN";
+        } else if (logger.isErrorEnabled()) {
+            logLevel = "ERROR";
         } else {
             logLevel = "OFF";
         }