Try current raw tablet format first

Author: Caideyipi

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

@@ -159,9 +159,11 @@ private void deserializeTPipeTransferRawReq(
       final ByteBuffer buffer, final TabletStringInternPool tabletStringInternPool) {
     final int startPosition = buffer.position();
     try {
+      // Current V1 raw tablet requests can be converted to InsertTabletStatement directly. Keep
+      // this as the first attempt to avoid the overhead of constructing an intermediate Tablet.
       final InsertTabletStatement insertTabletStatement =
-          TabletStatementConverter.deserializeLegacyStatementFromTabletFormat(
-              buffer, tabletStringInternPool);
+          TabletStatementConverter.deserializeStatementFromTabletFormat(
+              buffer, false, tabletStringInternPool);
       isAligned = insertTabletStatement.isAligned();
       statement = insertTabletStatement;
       return;
@@ -170,16 +172,20 @@ private void deserializeTPipeTransferRawReq(
     }
 
     try {
+      // Some old senders serialize Tablet without column categories. Retry with the legacy reader
+      // before falling back to the full Tablet deserialization path.
       final InsertTabletStatement insertTabletStatement =
-          TabletStatementConverter.deserializeStatementFromTabletFormat(
-              buffer, false, tabletStringInternPool);
+          TabletStatementConverter.deserializeLegacyStatementFromTabletFormat(
+              buffer, tabletStringInternPool);
       isAligned = insertTabletStatement.isAligned();
       statement = insertTabletStatement;
+      return;
     } catch (final Exception e) {
       buffer.position(startPosition);
-      tablet = PipeTabletUtils.internTablet(Tablet.deserialize(buffer), tabletStringInternPool);
-      isAligned = ReadWriteIOUtils.readBool(buffer);
     }
+
+    tablet = PipeTabletUtils.internTablet(Tablet.deserialize(buffer), tabletStringInternPool);
+    isAligned = ReadWriteIOUtils.readBool(buffer);
   }
 
   /////////////////////////////// Air Gap ///////////////////////////////