This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/AlignByDeviceDebug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9f6f4cf6540ada1f6e9cc2094754bc3a44245e22 Merge: fe064b03bb b343478a41 Author: Minghui Liu <[email protected]> AuthorDate: Tue May 31 09:25:56 2022 +0800 Merge remote-tracking branch 'origin/master' into lmh/AlignByDeviceDebug .../service/AbstractThriftServiceThread.java | 38 +------ .../iotdb/db/engine/memtable/AbstractMemTable.java | 7 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 5 +- .../db/engine/storagegroup/TsFileProcessor.java | 2 +- .../SmoothQueueSlidingWindowAggregator.java | 1 + .../execution/operator/process/FilterOperator.java | 80 +++++++-------- .../operator/process/LinearFillOperator.java | 3 +- .../operator/process/TransformOperator.java | 70 +++++++------ .../operator/process/merge/SingleColumnMerger.java | 4 +- .../db/mpp/plan/statement/crud/QueryStatement.java | 4 + .../query/reader/chunk/MemAlignedPageReader.java | 10 +- .../java/org/apache/iotdb/db/service/DataNode.java | 9 +- .../java/org/apache/iotdb/db/service/IoTDB.java | 9 +- .../thrift/impl/DataNodeTSIServiceImpl.java | 24 ++--- .../java/org/apache/iotdb/db/wal/WALManager.java | 15 ++- .../allocation/AbstractNodeAllocationStrategy.java | 9 ++ .../db/wal/allocation/FirstCreateStrategy.java | 4 +- .../iotdb/db/wal/buffer/AbstractWALBuffer.java | 4 +- .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +- .../iotdb/db/wal/checkpoint/CheckpointManager.java | 40 +++++--- .../iotdb/db/wal/checkpoint/MemTableInfo.java | 1 - .../apache/iotdb/db/wal/io/CheckpointReader.java | 22 ++-- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 7 +- .../db/wal/recover/CheckpointRecoverUtils.java | 32 +++++- .../iotdb/db/wal/recover/WALNodeRecoverTask.java | 34 ++++++- .../iotdb/db/wal/utils/CheckpointFileUtils.java | 3 +- .../apache/iotdb/db/wal/utils/WALFileUtils.java | 30 +++--- .../execution/operator/LinearFillOperatorTest.java | 113 ++++++++++++++++++++- .../db/wal/allocation/FirstCreateStrategyTest.java | 2 +- .../db/wal/checkpoint/CheckpointManagerTest.java | 6 +- .../apache/iotdb/db/wal/io/CheckpointFileTest.java | 12 ++- .../iotdb/db/wal/node/ConsensusReqReaderTest.java | 14 +-- .../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +- .../iotdb/tsfile/read/common/block/TsBlock.java | 3 +- 34 files changed, 407 insertions(+), 219 deletions(-)
