(iotdb) branch check-shit updated: Update IoTDBDataNodeAsyncClientManager.java

[rong]

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

rong pushed a commit to branch check-shit
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/check-shit by this push:
     new 38496204906 Update IoTDBDataNodeAsyncClientManager.java
38496204906 is described below

commit 384962049064b1d9a5edfbae48ad39d9e1a13085
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Fri Jul 11 10:28:34 2025 +0800

    Update IoTDBDataNodeAsyncClientManager.java
---
 .../pipe/connector/client/IoTDBDataNodeAsyncClientManager.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBDataNodeAsyncClientManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBDataNodeAsyncClientManager.java
index 8b23e52710f..a2f75bf110a 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBDataNodeAsyncClientManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBDataNodeAsyncClientManager.java
@@ -359,11 +359,15 @@ public class IoTDBDataNodeAsyncClientManager extends 
IoTDBClientManager
                   
ASYNC_PIPE_DATA_TRANSFER_CLIENT_MANAGER_HOLDER.remove(receiverAttributes);
               if (clientManager != null) {
                 try {
-                  LOGGER.warn("AsyncPipeDataTransferServiceClient closed. 1", 
new Exception());
                   clientManager.close();
-                  LOGGER.warn("AsyncPipeDataTransferServiceClient closed. 2", 
new Exception());
+                  LOGGER.info(
+                      "Closed AsyncPipeDataTransferServiceClientManager for 
receiver attributes: {}",
+                      receiverAttributes);
                 } catch (final Exception e) {
-                  LOGGER.warn("Failed to close client manager.", e);
+                  LOGGER.warn(
+                      "Failed to close 
AsyncPipeDataTransferServiceClientManager for receiver attributes: {}",
+                      receiverAttributes,
+                      e);
                 }
               }
               return null;