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 a7a06b05bb714cd212f3c672a5b886a5ee82a705 Author: minwenjun <[email protected]> AuthorDate: Tue Sep 11 07:58:57 2018 +0800 [FLINK-10223][LOG]Logging with resourceId during taskmanager startup centralize location & resourceId info at the master node This closes #6679. --- .../java/org/apache/flink/runtime/resourcemanager/ResourceManager.java | 1 + .../java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java | 2 ++ .../src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala | 2 +- .../main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala | 2 +- 4 files changed, 5 insertions(+), 2 deletions(-) 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 eb6df19..1ce29af 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,6 +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); taskExecutors.put(taskExecutorResourceId, registration); taskManagerHeartbeatManager.monitorTarget(taskExecutorResourceId, new HeartbeatTarget<Void>() { diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java index afe22de..5c1f420 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java @@ -349,6 +349,8 @@ public class TaskManagerRunner implements FatalErrorHandler, AutoCloseableAsync checkNotNull(rpcService); checkNotNull(highAvailabilityServices); + LOG.info("Starting TaskManager with ResourceID: {}", resourceID); + InetAddress remoteAddress = InetAddress.getByName(rpcService.getAddress()); TaskManagerServicesConfiguration taskManagerServicesConfiguration = diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala index 6d27dc3..66630f4 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala @@ -350,7 +350,7 @@ class JobManager( hardwareInformation, numberOfSlots) => // we are being informed by the ResourceManager that a new task manager is available - log.debug(s"RegisterTaskManager: $msg") + log.info(s"RegisterTaskManager: $msg") val taskManager = sender() 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 c04084c..2008ad8 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 @@ -1831,7 +1831,7 @@ object TaskManager { taskManagerClass: Class[_ <: TaskManager]) : Unit = { - LOG.info("Starting TaskManager") + LOG.info(s"Starting TaskManager with ResourceID: $resourceID") // Bring up the TaskManager actor system first, bind it to the given address.
