Pipe: Prevent duplicate error logging in AsyncPipeDataTransferServiceClient (#16856)

* Fix: Prevent duplicate error logging in AsyncPipeDataTransferServiceClient

- Change printLogWhenEncounterException from final to mutable field
- Set printLogWhenEncounterException to false in onError() to avoid repeated error logs
- This prevents flooding logs when client encounters errors

* update

(cherry picked from commit f4d628a)

Author: luoluoyuyu

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTrackableHandler.java

@@ -64,6 +64,7 @@ public void onComplete(final TPipeTransferResp response) {
   public void onError(final Exception exception) {
     if (client != null) {
       ThriftClient.resolveException(exception, client);
+      client.setPrintLogWhenEncounterException(false);
     }
 
     if (connector.isClosed()) {

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncPipeDataTransferServiceClient.java

@@ -49,7 +49,7 @@ public class AsyncPipeDataTransferServiceClient extends IClientRPCService.AsyncC
   private static final AtomicInteger idGenerator = new AtomicInteger(0);
   private final int id = idGenerator.incrementAndGet();
 
-  private final boolean printLogWhenEncounterException;
+  private boolean printLogWhenEncounterException;
 
   private final TEndPoint endpoint;
   private final ClientManager<TEndPoint, AsyncPipeDataTransferServiceClient> clientManager;
@@ -85,6 +85,7 @@ public void onComplete() {
   public void onError(final Exception e) {
     super.onError(e);
     ThriftClient.resolveException(e, this);
+    setPrintLogWhenEncounterException(false);
     returnSelf(
         (i) -> i instanceof IllegalStateException && "Client has an error!".equals(i.getMessage()));
   }
@@ -106,6 +107,10 @@ public boolean printLogWhenEncounterException() {
     return printLogWhenEncounterException;
   }
 
+  public void setPrintLogWhenEncounterException(final boolean printLogWhenEncounterException) {
+    this.printLogWhenEncounterException = printLogWhenEncounterException;
+  }
+
   /**
    * return self, the method doesn't need to be called by the user and will be triggered after the
    * RPC is finished.