flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK-5492] Fix TaskManager log entry
Date Wed, 25 Jan 2017 13:44:18 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.2 d4b92bcf7 -> 887c074a7


[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/887c074a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/887c074a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/887c074a

Branch: refs/heads/release-1.2
Commit: 887c074a769d821cc210468dbe82b7b702ff6db5
Parents: d4b92bc
Author: Robert Metzger <rmetzger@apache.org>
Authored: Wed Jan 25 14:27:29 2017 +0100
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Wed Jan 25 14:44:02 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/887c074a/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 d2fb717..f1e74cd 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
@@ -1736,11 +1736,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(


Mime
View raw message