You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/06/12 07:25:47 UTC
(iotdb) 04/04: spotless
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 <87...@users.noreply.github.com>
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();