This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch Fix_flush in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit efb2598e7bba4b0bb795bbc7d85050f7aa5dfea8 Author: HTHou <[email protected]> AuthorDate: Thu Nov 25 13:24:33 2021 +0800 Fix calculate --- .../org/apache/iotdb/db/engine/memtable/AbstractMemTable.java | 8 ++------ .../apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java | 3 +-- 2 files changed, 3 insertions(+), 8 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java index 24c901e..c55a4a3 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java @@ -92,9 +92,7 @@ public abstract class AbstractMemTable implements IMemTable { private IWritableMemChunkGroup createMemChunkGroupIfNotExistAndGet( String deviceId, List<IMeasurementSchema> schemaList) { IWritableMemChunkGroup memChunkGroup = - memTableMap.computeIfAbsent( - deviceId, - k -> new WritableMemChunkGroup()); + memTableMap.computeIfAbsent(deviceId, k -> new WritableMemChunkGroup()); for (IMeasurementSchema schema : schemaList) { if (!memChunkGroup.contains(schema.getMeasurementId())) { seriesNumber++; @@ -107,9 +105,7 @@ public abstract class AbstractMemTable implements IMemTable { private IWritableMemChunkGroup createAlignedMemChunkGroupIfNotExistAndGet( String deviceId, List<IMeasurementSchema> schemaList) { IWritableMemChunkGroup memChunkGroup = - memTableMap.computeIfAbsent( - deviceId, - k -> new AlignedWritableMemChunkGroup(schemaList)); + memTableMap.computeIfAbsent(deviceId, k -> new AlignedWritableMemChunkGroup(schemaList)); for (IMeasurementSchema schema : schemaList) { if (!memChunkGroup.contains(schema.getMeasurementId())) { seriesNumber++; diff --git a/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java b/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java index 4a88394..fd6c408 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java @@ -62,8 +62,7 @@ public class WritableMemChunkGroup implements IWritableMemChunkGroup { private IWritableMemChunk createMemChunkIfNotExistAndGet(IMeasurementSchema schema) { return memChunkMap.computeIfAbsent( - schema.getMeasurementId(), - k -> new WritableMemChunk(schema)); + schema.getMeasurementId(), k -> new WritableMemChunk(schema)); } @Override
