This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 69704df4472 [enhancement](blacklist) print the detail stack that the
client is shutdown (#45850)
69704df4472 is described below
commit 69704df447264b061802c55152dc1f087f54001a
Author: yiguolei <[email protected]>
AuthorDate: Tue Dec 24 14:52:58 2024 +0800
[enhancement](blacklist) print the detail stack that the client is shutdown
(#45850)
---
.../src/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 9416687b587..a64826118cb 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 class BackendServiceClient {
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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
