This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch HTVector
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit da699d0d913cbd278cd8126241ba0b935ad18e27
Merge: 1daf2a2 fb51b68
Author: HTHou <[email protected]>
AuthorDate: Sun Mar 14 11:19:01 2021 +0800

    fix conflicts

 .../iotdb/db/engine/flush/MemTableFlushTask.java   |   2 +-
 .../metadata/AlignedTimeseriesException.java       |  31 ++++
 .../org/apache/iotdb/db/metadata/MManager.java     |  88 ++++++++++-
 .../java/org/apache/iotdb/db/metadata/MTree.java   | 172 ++++++++++++++++++---
 .../org/apache/iotdb/db/metadata/MetaUtils.java    |  15 ++
 .../iotdb/db/metadata/MManagerBasicTest.java       | 106 ++++++++++++-
 .../db/qp/physical/PhysicalPlanSerializeTest.java  |  20 +--
 .../java/org/apache/iotdb/rpc/TSStatusCode.java    |   1 +
 8 files changed, 384 insertions(+), 51 deletions(-)

diff --cc 
server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
index 3413082,7f9c91f..41144ca
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
@@@ -44,6 -45,8 +44,7 @@@ import java.util.concurrent.ExecutionEx
  import java.util.concurrent.Future;
  import java.util.concurrent.LinkedBlockingQueue;
  
 -import static org.apache.iotdb.db.rescon.PrimitiveArrayManager.ARRAY_SIZE;
+ 
  public class MemTableFlushTask {
  
    private static final Logger LOGGER = 
LoggerFactory.getLogger(MemTableFlushTask.class);
@@@ -160,7 -163,12 +161,6 @@@
        new Runnable() {
          private void writeOneSeries(
              TVList tvPairs, IChunkWriter seriesWriterImpl, TSDataType 
dataType) {
 -
 -          if (dataType == TSDataType.VECTOR) {
 -            writeOneVectorSeries(tvPairs, seriesWriterImpl);
 -            return;
 -          }
--
            for (int i = 0; i < tvPairs.size(); i++) {
              long time = tvPairs.getTime(i);
  

Reply via email to