[FLINK-2792] [jobmanager, logging] Set actor message log level to TRACE
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3aaee1e5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3aaee1e5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3aaee1e5 Branch: refs/heads/master Commit: 3aaee1e51bae383b8c884a99b5523c25310c011d Parents: b233946 Author: Ufuk Celebi <[email protected]> Authored: Wed Sep 30 16:38:37 2015 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue Oct 20 00:16:51 2015 +0200 ---------------------------------------------------------------------- .../src/main/scala/org/apache/flink/runtime/LogMessages.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/3aaee1e5/flink-runtime/src/main/scala/org/apache/flink/runtime/LogMessages.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/LogMessages.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/LogMessages.scala index e1e8961..e4c1747 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/LogMessages.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/LogMessages.scala @@ -29,18 +29,18 @@ trait LogMessages extends FlinkActor { override def isDefinedAt(x: Any): Boolean = _receive.isDefinedAt(x) override def apply(x: Any): Unit = { - if (!log.isDebugEnabled) { + if (!log.isTraceEnabled) { _receive(x) } else { - log.debug(s"Received message $x at ${context.self.path} from ${context.sender()}.") + log.trace(s"Received message $x at ${context.self.path} from ${context.sender()}.") val start = System.nanoTime() _receive(x) val duration = (System.nanoTime() - start) / 1000000 - log.debug(s"Handled message $x in $duration ms from ${context.sender()}.") + log.trace(s"Handled message $x in $duration ms from ${context.sender()}.") } } }
