From b94eba9f11af66b10638dd255c224e946d842b8c Mon Sep 17 00:00:00 2001 From: Wei-Chiu Chuang Date: Thu, 1 Aug 2019 15:50:43 -0700 Subject: [PATCH] HADOOP-12282. Connection thread's name should be updated after address changing is detected. Contributed by Lisheng Sun. --- .../src/main/java/org/apache/hadoop/ipc/Client.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java index 3afa6d80b8..358c0d7ac3 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java @@ -638,6 +638,10 @@ public class Client implements AutoCloseable { LOG.warn("Address change detected. Old: " + server.toString() + " New: " + currentAddr.toString()); server = currentAddr; + UserGroupInformation ticket = remoteId.getTicket(); + this.setName("IPC Client (" + socketFactory.hashCode() + + ") connection to " + server.toString() + " from " + + ((ticket == null) ? "an unknown user" : ticket.getUserName())); return true; } return false;