You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2021/12/16 14:03:45 UTC
[flink] branch release-1.14 updated: [FLINK-25326][connectors/kafka] Fix application of log levels in KafaUtils.createKafkacontainer
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ß <11...@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";
}