Repository: flink
Updated Branches:
  refs/heads/master 82cda12ef -> 90834ca70


[FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to 
log level WARNING.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90834ca7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90834ca7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/90834ca7

Branch: refs/heads/master
Commit: 90834ca706d369b7c2bd739835766c490ee44042
Parents: 82cda12
Author: Till Rohrmann <trohrm...@apache.org>
Authored: Wed Feb 11 18:54:18 2015 +0100
Committer: Till Rohrmann <trohrm...@apache.org>
Committed: Wed Feb 11 18:54:18 2015 +0100

----------------------------------------------------------------------
 .../src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala | 4 +---
 .../org/apache/flink/runtime/testingUtils/TestingUtils.scala     | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/90834ca7/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala 
b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
index afbb6dd..ec5f7fa 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
@@ -140,7 +140,7 @@ object AkkaUtils {
         | serialize-messages = off
         |
         | loglevel = $logLevel
-        | stdout-loglevel = $logLevel
+        | stdout-loglevel = WARNING
         |
         | log-dead-letters = $logLifecycleEvents
         | log-dead-letters-during-shutdown = $logLifecycleEvents
@@ -201,8 +201,6 @@ object AkkaUtils {
 
     val logLifecycleEvents = if (lifecycleEvents) "on" else "off"
 
-    val logLevel = getLogLevel
-
     val configString =
       s"""
          |akka {

http://git-wip-us.apache.org/repos/asf/flink/blob/90834ca7/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
 
b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
index a9d8f51..6f70cb2 100644
--- 
a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
+++ 
b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
@@ -48,7 +48,7 @@ object TestingUtils {
       |akka.test.timefactor = 10
       |akka.loggers = ["akka.event.slf4j.Slf4jLogger"]
       |akka.loglevel = $logLevel
-      |akka.stdout-loglevel = $logLevel
+      |akka.stdout-loglevel = WARNING
       |akka.jvm-exit-on-fata-error = off
       |akka.log-config-on-start = off
     """.stripMargin

Reply via email to