Skip to content

Commit

Permalink
[FLINK-2792] [jobmanager, logging] Set actor message log level to TRACE
Browse files Browse the repository at this point in the history
  • Loading branch information
uce committed Sep 30, 2015
1 parent e85c179 commit a50899b
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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()}.")
}
}
}
Expand Down

0 comments on commit a50899b

Please sign in to comment.