From 69704df447264b061802c55152dc1f087f54001a Mon Sep 17 00:00:00 2001 From: yiguolei Date: Tue, 24 Dec 2024 14:52:58 +0800 Subject: [PATCH] [enhancement](blacklist) print the detail stack that the client is shutdown (#45850) --- .../main/java/org/apache/doris/rpc/BackendServiceClient.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java b/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java index 9416687b5877a1..a64826118cb40b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/rpc/BackendServiceClient.java @@ -189,9 +189,12 @@ public Future getBeResource(InternalServ return stub.withDeadlineAfter(timeoutSec, TimeUnit.SECONDS).getBeResource(request); } + // Shutdown will also interrupt the coordinators that are using this client to receive data. + // And the backend will be add to blacklist and will not serve read or write. public void shutdown() { ConnectivityState state = channel.getState(false); - LOG.warn("shut down backend service client: {}, channel state: {}", address, state); + // Print the detail exception stack, so that we could find the reason why it is treat as bad. + LOG.warn("shut down backend service client: {}, channel state: {}", address, state, new Exception()); if (!channel.isShutdown()) { channel.shutdown(); try {