[flink] 02/02: [FLINK-10223][logging] Add 'ResourceID' to log message.

[gary]

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

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

commit f1718cfd2e33c2d2e91636d55d72880327fe9fe0
Author: gyao <g...@data-artisans.com>
AuthorDate: Thu Sep 13 15:48:09 2018 +0200

    [FLINK-10223][logging] Add 'ResourceID' to log message.
---
 .../java/org/apache/flink/runtime/resourcemanager/ResourceManager.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
index 1ce29af..3984483 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
@@ -710,7 +710,7 @@ public abstract class ResourceManager<WorkerType extends 
ResourceIDRetrievable>
                        WorkerRegistration<WorkerType> registration =
                                new WorkerRegistration<>(taskExecutorGateway, 
newWorker, dataPort, hardwareDescription);
 
-                       log.info("Registering TaskManager {} ({}) at 
ResourceManager", taskExecutorResourceId, taskExecutorAddress);
+                       log.info("Registering TaskManager with ResourceID {} 
({}) at ResourceManager", taskExecutorResourceId, taskExecutorAddress);
                        taskExecutors.put(taskExecutorResourceId, registration);
 
                        
taskManagerHeartbeatManager.monitorTarget(taskExecutorResourceId, new 
HeartbeatTarget<Void>() {