You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2015/10/20 09:58:58 UTC
[07/47] flink git commit: [FLINK-2792] [jobmanager,
logging] Set actor message log level to TRACE
[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 <uc...@apache.org>
Authored: Wed Sep 30 16:38:37 2015 +0200
Committer: Till Rohrmann <tr...@apache.org>
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()}.")
}
}
}