You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/05/17 14:53:30 UTC
[iotdb] branch jira3188 updated (3b5fb85164 -> 1067865a13)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira3188
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 3b5fb85164 split dataRegion/schemaRegion consensus protocol && multiLeaderConsensus init
add b452368eb9 Report cpu core and total memory to config node (#5914)
add 7942b02c47 [IOTDB-3183] Cancel the singleton mode in the ConfigNode's persistence module (#5913)
add fa06bbb432 [IOTDB-2880] move procedure module into confignode as a class-package (#5899)
add 06b96322f0 [MPP][Bug hotfix] Support expressions in select and filter causes (#5918)
add 2d4b5bc1ac [IOTDB-2689] [IOTDB-2690] Simple Partition load balancing (#5910)
add b1734a082a [IOTDB-3160] TsFile will be corrupted when flushing memtable appears OOM (#5892)
add 7d91044dda [IOTDB-3181] Region expansion based on the total number of cpu cores (#5919)
add dbee2b89be [IOTDB-2978][compaction error log ] Log level and "null" error message handling (#5917)
add 719a77ac5e [IOTDB-2963] metrics of process and hardware (#5406)
add 434004fc63 [IOTDB-3092] Pooling config node clients using ClientManager (#5847)
add 7a7e390680 [IOTDB-2844] Implementaion of AggregationOperator and RawDataAggregationOperator (#5846)
add f7f857e562 [IOTDB-3062] add last cache in DataNodeSchemaCache (#5906)
add e108016b52 remove enable_performance_stat in iotdb-engine.properties, and add enablePerformanceStat in iotdb-metric.yml (#5920)
add 5032057a36 [IOTDB-3201] Support RowDataQuery API for new cluster (#5922)
add c76113ac45 BugFix: Delete snapshotDir on failure (#5927)
add b0d58269b3 [IOTDB-3210]fix npe (#5932)
add c0529f57aa fix a bug for system.properties (#5933)
add 7042883fc0 [IOTDB-3219] fix stop-server on windows (#5936)
add 1067865a13 split dataRegion/schemaRegion consensus protocol && multiLeaderConsensus init
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3b5fb85164)
\
N -- N -- N refs/heads/jira3188 (1067865a13)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
LICENSE | 14 +
confignode/pom.xml | 5 -
.../resources/conf/iotdb-confignode.properties | 4 +-
.../assembly/resources/sbin/stop-confignode.bat | 2 +-
.../confignode/client/AsyncDataNodeClientPool.java | 128 ++++++-
.../iotdb/confignode/conf/ConfigNodeConf.java | 4 +-
.../consensus/request/write/CreateRegionsReq.java | 32 +-
.../request/write/RegisterDataNodeReq.java | 22 +-
.../request/write/UpdateProcedureReq.java | 4 +-
...deLocationsResp.java => DataNodeInfosResp.java} | 18 +-
.../statemachine/PartitionRegionStateMachine.java | 6 +-
.../confignode/manager/ClusterSchemaManager.java | 18 +-
.../iotdb/confignode/manager/ConfigManager.java | 39 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 10 +-
.../apache/iotdb/confignode/manager/Manager.java | 4 +-
.../iotdb/confignode/manager/NodeManager.java | 51 ++-
.../iotdb/confignode/manager/PartitionManager.java | 80 +++--
.../confignode/manager/PermissionManager.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 36 +-
.../iotdb/confignode/manager/load/LoadManager.java | 267 ++++++---------
.../manager/load/balancer/RegionBalancer.java | 94 +++++-
.../allocator/CopySetRegionAllocator.java | 25 +-
.../{ => balancer}/allocator/IRegionAllocator.java | 6 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 12 -
.../confignode/persistence/ClusterSchemaInfo.java | 95 +++---
.../iotdb/confignode/persistence/NodeInfo.java | 94 +++---
.../confignode/persistence/PartitionInfo.java | 137 +++++---
.../confignode/persistence/ProcedureInfo.java | 21 +-
.../executor/ConfigRequestExecutor.java | 18 +-
.../procedure/CompletedProcedureContainer.java | 6 +-
.../procedure/CompletedProcedureRecycler.java | 20 +-
.../confignode}/procedure/InternalProcedure.java | 6 +-
.../iotdb/confignode}/procedure/Procedure.java | 66 ++--
.../confignode}/procedure/ProcedureExecutor.java | 75 +++--
.../confignode}/procedure/RootProcedureStack.java | 6 +-
.../procedure/StateMachineProcedure.java | 10 +-
.../confignode}/procedure/StoppableThread.java | 2 +-
.../procedure/TimeoutExecutorThread.java | 2 +-
.../procedure/conf/ProcedureNodeConfig.java | 6 +-
.../conf/ProcedureNodeConfigDescriptor.java | 2 +-
.../procedure/conf/ProcedureNodeConstant.java | 2 +-
.../exception/ProcedureAbortedException.java | 2 +-
.../procedure/exception/ProcedureException.java | 2 +-
.../exception/ProcedureSuspendedException.java | 2 +-
.../exception/ProcedureTimeoutException.java | 2 +-
.../exception/ProcedureYieldException.java | 2 +-
.../{ => impl}/DeleteStorageGroupProcedure.java | 55 +--
.../scheduler/AbstractProcedureScheduler.java | 4 +-
.../procedure/scheduler/ProcedureScheduler.java | 4 +-
.../scheduler/SimpleProcedureScheduler.java | 4 +-
.../{ => state}/DeleteStorageGroupState.java | 4 +-
.../procedure/state}/ProcedureLockState.java | 2 +-
.../confignode/procedure/state/ProcedureState.java | 12 +-
.../{ => store}/ConfigProcedureStore.java | 21 +-
.../procedure/store/IProcedureFactory.java | 4 +-
.../procedure/store/IProcedureStore.java | 8 +-
.../procedure/{ => store}/ProcedureFactory.java | 11 +-
.../procedure/store/ProcedureStore.java | 8 +-
.../confignode}/procedure/store/ProcedureWAL.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 13 +-
.../consensus/request/ConfigRequestSerDeTest.java | 13 +-
.../hash/DeviceGroupHashExecutorManualTest.java | 3 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 14 +-
.../confignode/persistence/PartitionInfoTest.java | 56 +++-
.../confignode}/procedure/NoopProcedureStore.java | 8 +-
.../confignode}/procedure/TestLockRegime.java | 6 +-
.../iotdb/confignode}/procedure/TestProcEnv.java | 4 +-
.../confignode}/procedure/TestProcedureBase.java | 11 +-
.../procedure/TestProcedureExecutor.java | 10 +-
.../confignode}/procedure/TestSTMProcedure.java | 6 +-
.../confignode}/procedure/entity/IncProcedure.java | 10 +-
.../procedure/entity/NoopProcedure.java | 10 +-
.../procedure/entity/SimpleLockProcedure.java | 14 +-
.../procedure/entity/SimpleSTMProcedure.java | 12 +-
.../procedure/entity/SleepProcedure.java | 12 +-
.../procedure/entity/StuckProcedure.java | 6 +-
.../procedure/entity/StuckSTMProcedure.java | 12 +-
.../procedure/entity/TestProcedureFactory.java | 6 +-
.../procedure/store/TestProcedureStore.java | 29 +-
.../procedure/util/ProcedureTestUtil.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 52 +--
.../ratis/ApplicationStateMachineProxy.java | 9 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 41 ++-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 42 ++-
.../iotdb/db/integration/IoTDBRestartIT.java | 101 ++++--
.../main/assembly/resources/conf/iotdb-metric.yml | 3 +
.../iotdb/metrics/DoNothingMetricService.java | 10 +
.../org/apache/iotdb/metrics/MetricService.java | 13 +
.../apache/iotdb/metrics/config/MetricConfig.java | 11 +
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 ++
pom.xml | 2 -
procedure/pom.xml | 93 ------
.../procedure/env/ClusterProcedureEnvironment.java | 25 --
.../iotdb/procedure/service/ProcedureNode.java | 98 ------
.../iotdb/procedure/service/ProcedureServer.java | 117 -------
.../service/ProcedureServerCommandLine.java | 52 ---
.../service/ProcedureServerProcessor.java | 87 -----
.../procedure/service/ProcedureServiceHanlder.java | 45 ---
.../procedure/service/TestProcedureService.java | 89 -----
.../resources/conf/iotdb-engine.properties | 4 -
.../src/assembly/resources/sbin/stop-datanode.bat | 2 +
server/src/assembly/resources/sbin/stop-server.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 31 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 326 ++++++++++++++----
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 160 +++++++++
.../iotdb/db/client/DataNodeClientPoolFactory.java | 18 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 7 -
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 51 +--
.../compaction/cross/CrossSpaceCompactionTask.java | 9 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 16 +-
.../impl/ReadPointCompactionPerformer.java | 7 +-
.../compaction/task/AbstractCompactionTask.java | 7 +-
.../db/engine/storagegroup/TsFileProcessor.java | 54 ++-
.../metadata/cache/DataNodeLastCacheManager.java | 81 +++++
.../db/metadata/cache/DataNodeSchemaCache.java | 34 ++
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 19 ++
.../iotdb/db/mpp/aggregation/Accumulator.java | 3 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 39 ++-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 38 ++-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 8 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 23 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 25 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 32 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 48 +--
.../db/mpp/aggregation/MaxTimeAccumulator.java | 24 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 17 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 22 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 20 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 22 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 34 +-
.../timerangeiterator/AggrWindowIterator.java | 172 ++++++++++
.../timerangeiterator/ITimeRangeIterator.java | 58 ++++
.../timerangeiterator/PreAggrWindowIterator.java | 169 ++++++++++
.../PreAggrWindowWithNaturalMonthIterator.java | 143 ++++++++
.../SingleTimeWindowIterator.java | 7 +-
.../TimeRangeIteratorFactory.java | 73 ++++
.../operator/process/AggregateOperator.java | 90 ++++-
.../execution/operator/process/FilterOperator.java | 25 +-
.../operator/process/RawDataAggregateOperator.java | 194 +++++++++++
.../operator/process/TransformOperator.java | 45 ++-
.../source/SeriesAggregateScanOperator.java | 107 +++---
.../db/mpp/execution/schedule/DriverScheduler.java | 2 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 8 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 1 +
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 51 +--
.../execution/config/AuthorizerConfigTask.java | 37 ++-
.../mpp/plan/execution/config/ConfigExecution.java | 14 +-
.../execution/config/CountStorageGroupTask.java | 16 +-
.../execution/config/DeleteStorageGroupTask.java | 17 +-
.../db/mpp/plan/execution/config/IConfigTask.java | 8 +-
.../plan/execution/config/SetStorageGroupTask.java | 19 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 20 +-
.../execution/config/ShowStorageGroupTask.java | 20 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 20 +-
.../db/mpp/plan/parser/StatementGenerator.java | 39 +--
.../db/mpp/plan/planner/DistributionPlanner.java | 51 ++-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 91 ++++-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 2 +-
.../planner/plan/node/process/AggregationNode.java | 64 +++-
.../plan/node/process/GroupByLevelNode.java | 6 +-
.../node/source/SeriesAggregationScanNode.java | 12 +-
.../plan/parameter/AggregationDescriptor.java | 61 +++-
.../planner/plan/parameter/AggregationStep.java | 44 ++-
.../iotdb/db/query/expression/Expression.java | 19 +-
.../query/expression/binary/BinaryExpression.java | 64 +++-
.../db/query/expression/leaf/ConstantOperand.java | 26 ++
.../query/expression/leaf/TimeSeriesOperand.java | 38 +++
.../db/query/expression/leaf/TimestampOperand.java | 33 ++
.../query/expression/multi/FunctionExpression.java | 115 +++++++
.../db/query/expression/unary/UnaryExpression.java | 50 +++
.../db/query/udf/core/executor/UDTFExecutor.java | 27 ++
.../query/udf/core/layer/EvaluationDAGBuilder.java | 25 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 28 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 7 +-
.../apache/iotdb/db/service/metrics/Metric.java | 20 +-
.../iotdb/db/service/metrics/MetricsService.java | 19 ++
.../db/service/metrics/ProcessMetricsMonitor.java | 148 +++++++++
.../db/service/metrics/SysRunMetricsMonitor.java | 134 ++++++++
.../thrift/impl/DataNodeTSIServiceImpl.java | 60 +++-
.../db/service/thrift/impl/TSServiceImpl.java | 3 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 69 ++++
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 116 +++++--
.../db/mpp/aggregation/TimeRangeIteratorTest.java | 298 +++++++++++++++++
.../db/mpp/execution/ConfigExecutionTest.java | 16 +-
.../execution/operator/AggregateOperatorTest.java | 321 ++++++++++++++++++
.../operator/RawDataAggregateOperatorTest.java | 368 +++++++++++++++++++++
.../operator/SeriesAggregateScanOperatorTest.java | 25 +-
.../node/process/AggregationNodeSerdeTest.java | 228 +++++++++++++
thrift-commons/src/main/thrift/common.thrift | 6 +
.../src/main/thrift/confignode.thrift | 8 +-
thrift-procedure/pom.xml | 66 ----
thrift-procedure/src/main/thrift/procedure.thrift | 42 ---
.../apache/iotdb/tsfile/read/common/TimeRange.java | 20 +-
.../write/writer/RestorableTsFileIOWriter.java | 37 +--
200 files changed, 5918 insertions(+), 2200 deletions(-)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{DataNodeLocationsResp.java => DataNodeInfosResp.java} (70%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/{ => balancer}/allocator/CopySetRegionAllocator.java (84%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/{ => balancer}/allocator/IRegionAllocator.java (90%)
rename procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureRetainer.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureContainer.java (87%)
rename procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureCleaner.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecycler.java (80%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/InternalProcedure.java (89%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/Procedure.java (90%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/ProcedureExecutor.java (90%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/RootProcedureStack.java (96%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/StateMachineProcedure.java (95%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/StoppableThread.java (97%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/TimeoutExecutorThread.java (98%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/conf/ProcedureNodeConfig.java (95%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/conf/ProcedureNodeConfigDescriptor.java (99%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/conf/ProcedureNodeConstant.java (96%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/exception/ProcedureAbortedException.java (94%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/exception/ProcedureException.java (95%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/exception/ProcedureSuspendedException.java (95%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/exception/ProcedureTimeoutException.java (94%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/exception/ProcedureYieldException.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/{ => impl}/DeleteStorageGroupProcedure.java (81%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/scheduler/AbstractProcedureScheduler.java (98%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/scheduler/ProcedureScheduler.java (96%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/scheduler/SimpleProcedureScheduler.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/{ => state}/DeleteStorageGroupState.java (91%)
rename {procedure/src/main/java/org/apache/iotdb/procedure => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state}/ProcedureLockState.java (94%)
rename procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNodeMBean.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/ProcedureState.java (82%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/{ => store}/ConfigProcedureStore.java (86%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/store/IProcedureFactory.java (89%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/store/IProcedureStore.java (81%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/{ => store}/ProcedureFactory.java (84%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/store/ProcedureStore.java (95%)
rename {procedure/src/main/java/org/apache/iotdb => confignode/src/main/java/org/apache/iotdb/confignode}/procedure/store/ProcedureWAL.java (96%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/NoopProcedureStore.java (84%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/TestLockRegime.java (89%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/TestProcEnv.java (93%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/TestProcedureBase.java (82%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/TestProcedureExecutor.java (92%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/TestSTMProcedure.java (91%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/IncProcedure.java (85%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/NoopProcedure.java (79%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/SimpleLockProcedure.java (83%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/SimpleSTMProcedure.java (86%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/SleepProcedure.java (80%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/StuckProcedure.java (91%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/StuckSTMProcedure.java (87%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/entity/TestProcedureFactory.java (92%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/store/TestProcedureStore.java (76%)
rename {procedure/src/test/java/org/apache/iotdb => confignode/src/test/java/org/apache/iotdb/confignode}/procedure/util/ProcedureTestUtil.java (88%)
delete mode 100644 procedure/pom.xml
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/env/ClusterProcedureEnvironment.java
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNode.java
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServer.java
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerCommandLine.java
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerProcessor.java
delete mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServiceHanlder.java
delete mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/service/TestProcedureService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/ConfigNodeInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeLastCacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/timerangeiterator/AggrWindowIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/timerangeiterator/ITimeRangeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/timerangeiterator/PreAggrWindowIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
rename server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/SingleTimeWindowIterator.java (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/timerangeiterator/TimeRangeIteratorFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/RawDataAggregateOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/ProcessMetricsMonitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/SysRunMetricsMonitor.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/aggregation/TimeRangeIteratorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/AggregateOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/RawDataAggregateOperatorTest.java
delete mode 100644 thrift-procedure/pom.xml
delete mode 100644 thrift-procedure/src/main/thrift/procedure.thrift