Skip to content

Commit a348f69

Browse files
committed
update
1 parent 934a8dc commit a348f69

File tree

1 file changed

+8
-12
lines changed

1 file changed

+8
-12
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/TabletStatementConverter.java

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -160,18 +160,14 @@ public static Tablet convertStatementToTablet(final InsertTabletStatement statem
160160
// Tablet(String tableName, List<IMeasurementSchema> schemas, List<ColumnCategory>
161161
// columnTypes,
162162
// long[] timestamps, Object[] values, BitMap[] bitMaps, int rowSize)
163-
final Tablet tablet =
164-
new Tablet(
165-
deviceIdOrTableName,
166-
schemas,
167-
tabletColumnTypes,
168-
timestamps,
169-
tabletValues,
170-
bitMaps,
171-
rowSize);
172-
173-
// Note: isAligned is not a property of Tablet, it's handled separately during insertion
174-
return tablet;
163+
return new Tablet(
164+
deviceIdOrTableName,
165+
schemas,
166+
tabletColumnTypes,
167+
timestamps,
168+
tabletValues,
169+
bitMaps,
170+
rowSize);
175171
} catch (final Exception e) {
176172
throw new MetadataException("Failed to convert InsertTabletStatement to Tablet", e);
177173
}

0 commit comments

Comments
 (0)