Skip to content

Commit 6a7afa4

Browse files
committed
fix
1 parent c08dfae commit 6a7afa4

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -244,8 +244,7 @@ private <T extends Pair<Tablet, List<Pair<IDeviceID, Integer>>>> T tryBestToAggr
244244
aggregatedSchemas.addAll(tablet.getSchemas());
245245
aggregatedColumnCategories.addAll(tablet.getColumnTypes());
246246
aggregatedValues.addAll(Arrays.asList(tablet.getValues()));
247-
aggregatedBitMaps.addAll(
248-
Arrays.asList(PipeTabletUtils.copyBitMapsOrCreateEmpty(tablet)));
247+
aggregatedBitMaps.addAll(Arrays.asList(PipeTabletUtils.copyBitMapsOrCreateEmpty(tablet)));
249248
// Remove the aggregated tablet
250249
tablets.pollFirst();
251250
} else {

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,8 +231,7 @@ private Tablet tryBestToAggregateTablets(
231231
// Aggregate the current tablet's data
232232
aggregatedSchemas.addAll(tablet.getSchemas());
233233
aggregatedValues.addAll(Arrays.asList(tablet.getValues()));
234-
aggregatedBitMaps.addAll(
235-
Arrays.asList(PipeTabletUtils.copyBitMapsOrCreateEmpty(tablet)));
234+
aggregatedBitMaps.addAll(Arrays.asList(PipeTabletUtils.copyBitMapsOrCreateEmpty(tablet)));
236235
// Remove the aggregated tablet
237236
tablets.pollFirst();
238237
} else {

0 commit comments

Comments
 (0)