[flink] branch master updated: [FLINK-11165] Refine the task deploying log for easier finding of task locations

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 35d16f9  [FLINK-11165] Refine the task deploying log for easier finding of task locations
35d16f9 is described below

commit 35d16f9a14a175de5dafbf37bb45fa3a1d42a16e
Author: zhuzhu.zz <zh...@alibaba-inc.com>
AuthorDate: Fri Dec 14 18:07:32 2018 +0800

    [FLINK-11165] Refine the task deploying log for easier finding of task locations
---
 .../main/java/org/apache/flink/runtime/executiongraph/Execution.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index e3b501e..a48352c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -597,7 +597,7 @@ public class Execution implements AccessExecution, Archiveable<ArchivedExecution
 
 			if (LOG.isInfoEnabled()) {
 				LOG.info(String.format("Deploying %s (attempt #%d) to %s", vertex.getTaskNameWithSubtaskIndex(),
-						attemptNumber, getAssignedResourceLocation().getHostname()));
+						attemptNumber, getAssignedResourceLocation()));
 			}
 
 			final TaskDeploymentDescriptor deployment = vertex.createDeploymentDescriptor(