bug-fix

Author: Caideyipi

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

@@ -93,6 +93,7 @@ public synchronized void onSuccess() {
     binaryDataBases.clear();
     insertNodeDataBases.clear();
     tabletDataBases.clear();
+    tableModelTabletMap.clear();
 
     pipe2BytesAccumulated.clear();
   }
@@ -127,6 +128,8 @@ public PipeTransferTabletBatchReqV2 toTPipeTransferReq() throws IOException {
       }
     }
 
+    tableModelTabletMap.clear();
+
     return PipeTransferTabletBatchReqV2.toTPipeTransferReq(
         binaryBuffers,
         insertNodeBuffers,
@@ -146,7 +149,7 @@ public Map<Pair<String, Long>, Long> getPipe2BytesAccumulated() {
 
   private long buildTabletInsertionBuffer(final TabletInsertionEvent event) throws IOException {
     long estimateSize;
-    ByteBuffer buffer = null;
+    final ByteBuffer buffer;
     if (event instanceof PipeInsertNodeTabletInsertionEvent) {
       final PipeInsertNodeTabletInsertionEvent pipeInsertNodeTabletInsertionEvent =
           (PipeInsertNodeTabletInsertionEvent) event;