diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
index 1ef2cdc06dfbf..a0cf1d5c12736 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
@@ -134,7 +134,7 @@ public static ActorSystem startActorSystem(
 				int listeningPort,
 				Logger logger) throws Exception {
 
-		String hostPortUrl = NetUtils.hostAndPortToUrlString(listeningAddress, listeningPort);
+		String hostPortUrl = listeningAddress + ':' + listeningPort;
 		logger.info("Trying to start actor system at {}", hostPortUrl);
 
 		try {
@@ -146,7 +146,8 @@ public static ActorSystem startActorSystem(
 			logger.debug("Using akka configuration\n {}", akkaConfig);
 
 			ActorSystem actorSystem = AkkaUtils.createActorSystem(akkaConfig);
-			logger.info("Actor system started at {}", hostPortUrl);
+
+			logger.info("Actor system started at {}", AkkaUtils.getAddress(actorSystem));
 			return actorSystem;
 		}
 		catch (Throwable t) {
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 cd670696a47d5..7b0e7d096f3bf 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
@@ -1741,8 +1741,7 @@ object TaskManager {
 
     // Bring up the TaskManager actor system first, bind it to the given address.
     
-    LOG.info("Starting TaskManager actor system at " + 
-      NetUtils.hostAndPortToUrlString(taskManagerHostname, actorSystemPort))
+    LOG.info("Starting TaskManager actor system at {}:{}.", taskManagerHostname, actorSystemPort)
 
     val taskManagerSystem = try {
       val akkaConfig = AkkaUtils.getAkkaConfig(
@@ -1759,9 +1758,8 @@ object TaskManager {
         if (t.isInstanceOf[org.jboss.netty.channel.ChannelException]) {
           val cause = t.getCause()
           if (cause != null && t.getCause().isInstanceOf[java.net.BindException]) {
-            val address = NetUtils.hostAndPortToUrlString(taskManagerHostname, actorSystemPort)
             throw new IOException("Unable to bind TaskManager actor system to address " +
-              address + " - " + cause.getMessage(), t)
+              taskManagerHostname + ':' + actorSystemPort + " - " + cause.getMessage(), t)
           }
         }
         throw new Exception("Could not create TaskManager actor system", t)