try bug

Signed-off-by: OneSizeFitQuorum <[email protected]>
apache · Jun 27, 2024 · 4e82f3c · 4e82f3c
1 parent b4bb3dc
commit 4e82f3c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 7 deletions.
diff --git a/...g/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java b/...g/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
@@ -221,18 +221,21 @@ private void transferInEventWithoutCheck(final TabletInsertionEvent tabletInsert
 
       final InsertNode insertNode =
           pipeInsertNodeTabletInsertionEvent.getInsertNodeViaCacheIfPossible();
-      byte[] byte1 = pipeInsertNodeTabletInsertionEvent.getByteBuffer().array();
-      StringBuilder sb = new StringBuilder();
-      org.apache.thrift.TBaseHelper.toString(ByteBuffer.wrap(byte1), sb);
-      if (insertNode == null) {
-        LOGGER.error("unpected situation, byte1 {}, insertNode {}", sb, insertNode);
-      }
       final TPipeTransferReq pipeTransferReq =
           compressIfNeeded(
               Objects.isNull(insertNode)
                   ? PipeTransferTabletBinaryReq.toTPipeTransferReq(
                       pipeInsertNodeTabletInsertionEvent.getByteBuffer())
                   : PipeTransferTabletInsertNodeReq.toTPipeTransferReq(insertNode));
+      if (insertNode == null) {
+        LOGGER.error("unexpected situation, pipeTransferReq {}", pipeTransferReq);
+        ByteBuffer buffer = pipeTransferReq.body;
+        LOGGER.info(
+            "buffer capacity is: {}, limit is: {}, position is: {}",
+            buffer.capacity(),
+            buffer.limit(),
+            buffer.position());
+      }
       final PipeTransferTabletInsertNodeEventHandler pipeTransferInsertNodeReqHandler =
           new PipeTransferTabletInsertNodeEventHandler(
               pipeInsertNodeTabletInsertionEvent, pipeTransferReq, this);

diff --git a/...anode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java b/...anode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
@@ -130,7 +130,7 @@ public static WALEntry deserialize(DataInputStream stream) throws IOException {
    * InsertTabletNode.
    */
   public static PlanNode deserializeForConsensus(ByteBuffer buffer) {
-    logger.debug(
+    logger.info(
         "buffer capacity is: {}, limit is: {}, position is: {}",
         buffer.capacity(),
         buffer.limit(),