[FLINK-23898][akka] Fix log level mapping

WARN -> WARNING TRACE -> DEBUG
nicusX · Aug 22, 2021 · 5af5dd1 · 5af5dd1
1 parent 82c1cc1
commit 5af5dd1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java
@@ -112,7 +112,8 @@ private static Config getBasicAkkaConfig(Configuration configuration) {
 
     private static String getLogLevel() {
         if (LOG.isTraceEnabled()) {
-            return "TRACE";
+            // TRACE is not supported by akka
+            return "DEBUG";
         }
         if (LOG.isDebugEnabled()) {
             return "DEBUG";
@@ -121,7 +122,7 @@ private static String getLogLevel() {
             return "INFO";
         }
         if (LOG.isWarnEnabled()) {
-            return "WARN";
+            return "WARNING";
         }
         if (LOG.isErrorEnabled()) {
             return "ERROR";