This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch try_wal_ci in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c828009572eb42e1a4085f0d0ace2a1dce2aeaaa Merge: 64dfddc263 7b07fd9cba Author: HTHou <[email protected]> AuthorDate: Mon Jun 13 09:45:34 2022 +0800 Merge branch 'master' of https://github.com/apache/iotdb into try_wal_ci checkstyle.xml | 2 +- client-py/SessionExample.py | 11 ++ client-py/iotdb/Session.py | 35 ++++++- client-py/iotdb/tsfile/__init__.py | 17 ++++ client-py/iotdb/tsfile/common/__init__.py | 17 ++++ .../iotdb/consensus/ratis/RatisConsensus.java | 2 +- .../iotdb/consensus/ratis/SnapshotStorage.java | 59 +++++++++-- .../java/org/apache/iotdb/it/env/ConfigNode.java | 4 +- .../threadpool/ScheduledExecutorUtil.java | 104 +++++++++++++++++-- .../iotdb/commons/partition/DataPartition.java | 7 +- .../statemachine/visitor/DataExecutionVisitor.java | 10 -- .../org/apache/iotdb/db/engine/StorageEngine.java | 16 +-- .../apache/iotdb/db/engine/StorageEngineV2.java | 25 ++--- .../engine/compaction/CompactionTaskManager.java | 32 +++--- .../db/engine/storagegroup/TsFileResource.java | 6 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 4 +- .../localconfignode/LocalDataPartitionTable.java | 28 +++-- .../apache/iotdb/db/metadata/path/AlignedPath.java | 4 + .../metadata/visitor/SchemaExecutionVisitor.java | 14 --- .../execution/datatransfer/DataBlockService.java | 21 ++-- .../execution/datatransfer/SharedTsBlockQueue.java | 4 +- .../mpp/execution/datatransfer/SourceHandle.java | 2 +- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 16 --- .../mpp/plan/analyze/GroupByLevelController.java | 57 ++++++++++- .../db/mpp/plan/execution/QueryExecution.java | 3 +- .../plan/execution/memory/MemorySourceHandle.java | 4 +- .../db/mpp/plan/planner/LocalExecutionPlanner.java | 18 ++-- .../planner/distribution/DistributionPlanner.java | 2 +- .../planner/distribution/ExchangeNodeAdder.java | 19 +++- .../db/mpp/plan/planner/plan/FragmentInstance.java | 7 -- .../db/mpp/plan/planner/plan/PlanFragment.java | 3 +- .../plan/planner/plan/node/DeleteRegionNode.java | 113 --------------------- .../plan/planner/plan/node/PlanGraphPrinter.java | 20 +++- .../mpp/plan/planner/plan/node/PlanNodeType.java | 3 - .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 6 +- .../planner/plan/node/process/AggregationNode.java | 2 +- .../plan/node/process/LastQueryMergeNode.java | 3 +- .../plan/node/source/AlignedLastQueryScanNode.java | 4 +- .../source/AlignedSeriesAggregationScanNode.java | 10 ++ .../plan/node/source/AlignedSeriesScanNode.java | 4 +- .../node/source/SeriesAggregationScanNode.java | 1 + .../plan/parameter/AggregationDescriptor.java | 3 + .../java/org/apache/iotdb/db/service/DataNode.java | 47 ++++----- .../thrift/impl/DataNodeTSIServiceImpl.java | 10 +- .../service/thrift/impl/InternalServiceImpl.java | 110 ++++++++++++++------ .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 12 ++- .../mpp/plan/plan/FragmentInstanceSerdeTest.java | 7 ++ .../distribution/NoDataRegionPlanningTest.java | 84 +++++++++++++++ .../plan/node/write/DeleteRegionNodeSerdeTest.java | 60 ----------- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 + thrift/src/main/thrift/mpp.thrift | 31 ++---- 51 files changed, 656 insertions(+), 430 deletions(-)
