trimming

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTabletBatchReqV2.java

@@ -44,8 +44,6 @@
 import java.util.Map;
 import java.util.Objects;
 
-import static org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent.isTabletEmpty;
-
 public class PipeTransferTabletBatchReqV2 extends TPipeTransferReq {
 
   private final transient List<PipeTransferTabletBinaryReqV2> binaryReqs = new ArrayList<>();
@@ -148,12 +146,11 @@ public List<InsertBaseStatement> constructStatements() {
     }
 
     for (final PipeTransferTabletRawReqV2 tabletReq : tabletReqs) {
-      final Tablet tablet = tabletReq.tablet;
       final InsertTabletStatement statement = tabletReq.constructStatement();
-      if (isTabletEmpty(tablet)) {
+      if (statement.isEmpty()) {
         continue;
       }
-      if (Objects.nonNull(tabletReq.dataBaseName)) {
+      if (statement.isWriteToTable()) {
         statements.add(statement);
         continue;
       }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTabletRawReqV2.java

@@ -58,11 +58,6 @@ public String getDataBaseName() {
 
   @Override
   public InsertTabletStatement constructStatement() {
-    return constructStatement(tablet, dataBaseName, isAligned);
-  }
-
-  public static InsertTabletStatement constructStatement(
-      final Tablet tablet, final String dataBaseName, final boolean isAligned) {
     if (Objects.isNull(dataBaseName)) {
       new PipeTreeModelTabletEventSorter(tablet).deduplicateAndSortTimestampsIfNecessary();
     } else {

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeDescriptor.java

@@ -160,12 +160,6 @@ public static void loadPipeStaticConfig(CommonConfig config, TrimProperties prop
                 "pipe_listening_queue_transfer_snapshot_threshold",
                 String.valueOf(config.getPipeListeningQueueTransferSnapshotThreshold()))));
 
-    config.setPipeListeningQueueTransferSnapshotThreshold(
-        Long.parseLong(
-            properties.getProperty(
-                "pipe_listening_queue_transfer_snapshot_threshold",
-                String.valueOf(config.getPipeListeningQueueTransferSnapshotThreshold()))));
-
     config.setPipeSnapshotExecutionMaxBatchSize(
         Integer.parseInt(
             properties.getProperty(