Repository: flink Updated Branches: refs/heads/master 34e106f63 -> cf6b3fb22
[FLINK-5492] Fix TaskManager log entry Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf6b3fb2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf6b3fb2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cf6b3fb2 Branch: refs/heads/master Commit: cf6b3fb22c67a540dbfa96497d66041ba95ad358 Parents: 34e106f Author: Robert Metzger <rmetz...@apache.org> Authored: Wed Jan 25 14:27:29 2017 +0100 Committer: Robert Metzger <rmetz...@apache.org> Committed: Wed Jan 25 14:45:04 2017 +0100 ---------------------------------------------------------------------- .../org/apache/flink/runtime/taskmanager/TaskManager.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cf6b3fb2/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala index 3c142cd..7cb1902 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala @@ -1745,11 +1745,11 @@ object TaskManager { taskManagerClass: Class[_ <: TaskManager]) : Unit = { - LOG.info(s"Starting TaskManager") + LOG.info("Starting TaskManager") // Bring up the TaskManager actor system first, bind it to the given address. - - LOG.info("Starting TaskManager actor system at {}:{}.", taskManagerHostname, actorSystemPort) + + LOG.info(s"Starting TaskManager actor system at $taskManagerHostname:$actorSystemPort.") val taskManagerSystem = try { val akkaConfig = AkkaUtils.getAkkaConfig(
