Merge branch 'master' of https://github.com/apache/iotdb into fix-audit-logger

Author: Caideyipi

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/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertTabletStatement.java

@@ -20,6 +20,7 @@
 package org.apache.iotdb.db.queryengine.plan.statement.crud;
 
 import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
+import org.apache.iotdb.commons.conf.CommonDescriptor;
 import org.apache.iotdb.commons.exception.MetadataException;
 import org.apache.iotdb.commons.path.PartialPath;
 import org.apache.iotdb.commons.schema.table.column.TsTableColumnCategory;
@@ -702,11 +703,15 @@ protected void subRemoveAttributeColumns(List<Integer> columnsToKeep) {
 
   @Override
   public String toString() {
+    final int size = CommonDescriptor.getInstance().getConfig().getPathLogMaxSize();
     return "InsertTabletStatement{"
         + "deviceIDs="
         + Arrays.toString(deviceIDs)
         + ", measurements="
-        + Arrays.toString(measurements)
+        + Arrays.toString(
+            Objects.nonNull(measurements) && measurements.length > size
+                ? Arrays.copyOf(measurements, size)
+                : measurements)
         + ", rowCount="
         + rowCount
         + ", timeRange=["

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.

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java

@@ -35,6 +35,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.annotation.Nullable;
+
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
@@ -106,7 +108,7 @@ public void handle(
    */
   public void handle(
       final TSStatus status,
-      final String exceptionMessage,
+      final @Nullable String exceptionMessage,
       final String recordMessage,
       final boolean log4NoPrivileges) {
 
@@ -206,7 +208,7 @@ public void handle(
         break;
       default:
         // Some auth error may be wrapped in other codes
-        if (exceptionMessage.contains(NO_PERMISSION_STR)) {
+        if (Objects.nonNull(exceptionMessage) && exceptionMessage.contains(NO_PERMISSION_STR)) {
           if (skipIfNoPrivileges) {
             if (log4NoPrivileges && LOGGER.isWarnEnabled()) {
               LOGGER.warn(