This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch fix-legacy-compat-followup in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e9f3c8523105238cbc0d6a88f961b687a39151b4 Author: Caideyipi <[email protected]> AuthorDate: Fri Jun 12 14:23:26 2026 +0800 spotless --- .../apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java | 6 ++---- .../apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java | 3 +-- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java index 27032f4cfe3..5afe02658d9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java @@ -359,8 +359,7 @@ public class TabletStatementConverter { final byte value = ReadWriteIOUtils.readByte(buffer); if (value != 0 && value != 1) { throw new IllegalArgumentException( - String.format( - "Invalid %s flag %s in tablet format deserialization.", fieldName, value)); + String.format("Invalid %s flag %s in tablet format deserialization.", fieldName, value)); } return value == 1; } @@ -474,8 +473,7 @@ public class TabletStatementConverter { NUM_BYTES_ARRAY_HEADER + NUM_BYTES_OBJECT_REF * columns); for (int i = 0; i < columns; i++) { - final boolean isValueColumnsNotNull = - readBooleanByte(byteBuffer, "value column existence"); + final boolean isValueColumnsNotNull = readBooleanByte(byteBuffer, "value column existence"); if (types[i] == null) { continue; } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java index b95852aa936..7641070800f 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java @@ -756,8 +756,7 @@ public class PipeDataNodeThriftRequestTest { } @Test - public void testPipeTransferTabletRawReqWithSingleColumnLegacyTabletFormat() - throws IOException { + public void testPipeTransferTabletRawReqWithSingleColumnLegacyTabletFormat() throws IOException { final TPipeTransferReq req = new TPipeTransferReq(); req.version = IoTDBSinkRequestVersion.VERSION_1.getVersion(); req.type = PipeRequestType.TRANSFER_TABLET_RAW.getType();
