This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/addQueryIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b5a8455133 fix sonarcloud code smells
add e25536dfdf fix sonarcloud code smells
add 3304ab6f45 Fix getLeader NPE and ConfigNode expension failure (#6430)
add 8d20e48b09 Optimize multiLeaderConsensus performance (#6413)
add a47dcf39c5 avoid some exception in middle retry (#6433)
add bf36ca3a3f [IOTDB-3649] Fix stack overflow when deleting wal (#6432)
add 56d6940b01 Change default partition cache size to 0 (#6434)
add f329169c8d fix bug of 'all cols are null but return the row' value
filter (#6436)
add 2db985c526 not initialize schedule thread if all compaction is disable
(#6437)
add b4fd6acd2b [IOTDB-3499] Add align by device IT in MPP (#6415)
add 5ebe47c8b1 [IOTDB-3653] Fix SharedTsBlockQueueTest.concurrencyTest
failed in CI (#6440)
add e8984a2fbe rename DataBlockManager to MPPDataExchangeManager (#6444)
add 37bd158560 change mpp to mPP in thrift (#6445)
add 11c6c331e6 remove old cluster module from master branch (#6446)
add 8c82eb14bb upgrade spotless to fix jvmargs issue (#6441)
add 5008c7856a [IOTDB-3352] Fix partition cache (#6443)
add 51b8f124f3 Rename TRegionLocation and some parameters (#6447)
add 3062bdb623 rename iotdb-engine.properties to iotdb-datanode.properties
(#6449)
add e71044e1bb Enable partition cache and change default size to 10000
(#6448)
add 2e4f8b8240 Try to fix sonar test (#6457)
add 0eb5010414 Rename iotdb-env.sh to datanode-env.sh (#6455)
add 81c363e8dc [IOTDB-3260] Fix npe while concurrent delete storage group
(#6428)
add d3c4b6c7b7 Remove more code about old cluster module (#6461)
add e2ec158a1b Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add 196692f308 replace iotdb-engine.properties to iotdb-datanode.properties
No new revisions were added by this update.
Summary of changes:
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 14 +-
.github/workflows/sonar-coveralls.yml | 2 +-
README.md | 18 +-
README_ZH.md | 17 +-
cluster/pom.xml | 228 --
cluster/src/assembly/cluster.xml | 35 -
.../resources/conf/iotdb-cluster.properties | 200 --
cluster/src/assembly/resources/sbin/add-node.bat | 133 --
cluster/src/assembly/resources/sbin/add-node.sh | 95 -
cluster/src/assembly/resources/sbin/nodetool.bat | 58 -
cluster/src/assembly/resources/sbin/nodetool.sh | 48 -
.../src/assembly/resources/sbin/remove-node.bat | 110 -
cluster/src/assembly/resources/sbin/remove-node.sh | 72 -
cluster/src/assembly/resources/sbin/start-node.bat | 136 --
cluster/src/assembly/resources/sbin/start-node.sh | 97 -
cluster/src/assembly/resources/sbin/stop-node.bat | 27 -
cluster/src/assembly/resources/sbin/stop-node.sh | 39 -
.../java/org/apache/iotdb/cluster/ClientMain.java | 469 -----
.../iotdb/cluster/ClusterFileFlushPolicy.java | 75 -
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 675 ------
.../apache/iotdb/cluster/ClusterIoTDBMBean.java | 36 -
.../cluster/ClusterIoTDBServerCommandLine.java | 94 -
.../apache/iotdb/cluster/RemoteTsFileResource.java | 150 --
.../apache/iotdb/cluster/client/BaseFactory.java | 54 -
.../iotdb/cluster/client/ClientCategory.java | 38 -
.../apache/iotdb/cluster/client/ClientManager.java | 223 --
.../iotdb/cluster/client/ClientPoolFactory.java | 101 -
.../iotdb/cluster/client/IClientManager.java | 35 -
.../cluster/client/async/AsyncBaseFactory.java | 68 -
.../cluster/client/async/AsyncDataClient.java | 218 --
.../cluster/client/async/AsyncMetaClient.java | 178 --
.../cluster/client/sync/SyncClientAdaptor.java | 527 -----
.../iotdb/cluster/client/sync/SyncDataClient.java | 154 --
.../iotdb/cluster/client/sync/SyncMetaClient.java | 144 --
.../apache/iotdb/cluster/config/ClusterConfig.java | 584 ------
.../iotdb/cluster/config/ClusterConstant.java | 144 --
.../iotdb/cluster/config/ClusterDescriptor.java | 418 ----
.../iotdb/cluster/config/ConsistencyLevel.java | 67 -
.../iotdb/cluster/coordinator/Coordinator.java | 807 -------
.../iotdb/cluster/exception/AddSelfException.java | 28 -
.../exception/BadSeedUrlFormatException.java | 30 -
.../exception/ChangeMembershipException.java | 28 -
.../exception/CheckConsistencyException.java | 37 -
.../exception/ConfigInconsistentException.java | 29 -
.../cluster/exception/EmptyIntervalException.java | 28 -
.../cluster/exception/EntryCompactedException.java | 30 -
.../exception/EntryUnavailableException.java | 28 -
.../GetEntriesWrongParametersException.java | 27 -
.../cluster/exception/LeaderUnknownException.java | 31 -
.../cluster/exception/LogExecutionException.java | 27 -
.../cluster/exception/MemberReadOnlyException.java | 33 -
.../cluster/exception/NoHeaderNodeException.java | 31 -
.../cluster/exception/NotInSameGroupException.java | 32 -
.../cluster/exception/NotManagedSlotException.java | 33 -
.../PartitionTableUnavailableException.java | 30 -
.../iotdb/cluster/exception/PullFileException.java | 34 -
.../cluster/exception/QueryTimeOutException.java | 27 -
.../cluster/exception/ReaderNotFoundException.java | 27 -
.../cluster/exception/RequestTimeOutException.java | 34 -
.../exception/SnapshotInstallationException.java | 37 -
.../exception/StartUpCheckFailureException.java | 31 -
.../exception/TruncateCommittedEntryException.java | 30 -
.../cluster/exception/UnknownLogTypeException.java | 28 -
.../exception/UnsupportedPlanException.java | 29 -
.../iotdb/cluster/log/CommitLogCallback.java | 48 -
.../apache/iotdb/cluster/log/CommitLogTask.java | 65 -
.../org/apache/iotdb/cluster/log/HardState.java | 114 -
.../java/org/apache/iotdb/cluster/log/Log.java | 145 --
.../org/apache/iotdb/cluster/log/LogApplier.java | 35 -
.../apache/iotdb/cluster/log/LogDispatcher.java | 461 ----
.../org/apache/iotdb/cluster/log/LogParser.java | 110 -
.../org/apache/iotdb/cluster/log/Snapshot.java | 75 -
.../iotdb/cluster/log/StableEntryManager.java | 61 -
.../cluster/log/applier/AsyncDataLogApplier.java | 302 ---
.../iotdb/cluster/log/applier/BaseApplier.java | 263 ---
.../iotdb/cluster/log/applier/DataLogApplier.java | 185 --
.../iotdb/cluster/log/applier/MetaLogApplier.java | 90 -
.../iotdb/cluster/log/catchup/CatchUpTask.java | 403 ----
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 350 ---
.../cluster/log/catchup/SnapshotCatchUpTask.java | 159 --
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 136 --
.../iotdb/cluster/log/logtypes/CloseFileLog.java | 124 --
.../cluster/log/logtypes/EmptyContentLog.java | 63 -
.../iotdb/cluster/log/logtypes/LargeTestLog.java | 78 -
.../cluster/log/logtypes/PhysicalPlanLog.java | 115 -
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 131 --
.../cluster/log/manage/CommittedEntryManager.java | 301 ---
.../manage/FilePartitionedSnapshotLogManager.java | 259 ---
.../log/manage/MetaSingleSnapshotLogManager.java | 93 -
.../log/manage/PartitionedSnapshotLogManager.java | 137 --
.../iotdb/cluster/log/manage/RaftLogManager.java | 1038 ---------
.../log/manage/UnCommittedEntryManager.java | 276 ---
.../log/manage/serializable/LogManagerMeta.java | 143 --
.../serializable/SyncLogDequeSerializer.java | 1409 -------------
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 641 ------
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 342 ---
.../cluster/log/snapshot/PartitionedSnapshot.java | 223 --
.../cluster/log/snapshot/PullSnapshotTask.java | 269 ---
.../log/snapshot/PullSnapshotTaskDescriptor.java | 135 --
.../cluster/log/snapshot/SnapshotFactory.java | 28 -
.../cluster/log/snapshot/SnapshotInstaller.java | 33 -
.../log/snapshot/TimeseriesSchemaSnapshot.java | 31 -
.../iotdb/cluster/metadata/CSchemaProcessor.java | 1741 ---------------
.../apache/iotdb/cluster/metadata/MetaPuller.java | 452 ----
.../cluster/partition/NodeAdditionResult.java | 37 -
.../iotdb/cluster/partition/NodeRemovalResult.java | 61 -
.../iotdb/cluster/partition/PartitionGroup.java | 109 -
.../iotdb/cluster/partition/PartitionTable.java | 154 --
.../partition/balancer/DefaultSlotBalancer.java | 121 --
.../cluster/partition/balancer/SlotBalancer.java | 43 -
.../iotdb/cluster/partition/slot/SlotManager.java | 402 ----
.../partition/slot/SlotNodeAdditionResult.java | 40 -
.../partition/slot/SlotNodeRemovalResult.java | 79 -
.../cluster/partition/slot/SlotPartitionTable.java | 611 ------
.../iotdb/cluster/partition/slot/SlotStrategy.java | 48 -
.../partition/slot/SlotTimePartitionFilter.java | 56 -
.../cluster/query/ClusterDataQueryExecutor.java | 325 ---
.../cluster/query/ClusterPhysicalGenerator.java | 106 -
.../iotdb/cluster/query/ClusterPlanExecutor.java | 923 --------
.../iotdb/cluster/query/ClusterPlanRouter.java | 507 -----
.../apache/iotdb/cluster/query/ClusterPlanner.java | 35 -
.../iotdb/cluster/query/ClusterQueryRouter.java | 109 -
.../cluster/query/ClusterUDTFQueryExecutor.java | 103 -
.../iotdb/cluster/query/LocalQueryExecutor.java | 1066 ----------
.../iotdb/cluster/query/RemoteQueryContext.java | 73 -
.../query/aggregate/ClusterAggregateExecutor.java | 107 -
.../cluster/query/aggregate/ClusterAggregator.java | 292 ---
.../cluster/query/fill/ClusterFillExecutor.java | 104 -
.../cluster/query/fill/ClusterLinearFill.java | 80 -
.../cluster/query/fill/ClusterPreviousFill.java | 269 ---
.../cluster/query/fill/PreviousFillArguments.java | 70 -
.../iotdb/cluster/query/filter/SlotSgFilter.java | 47 -
.../cluster/query/filter/SlotTsFileFilter.java | 69 -
.../groupby/ClusterGroupByNoVFilterDataSet.java | 61 -
.../groupby/ClusterGroupByVFilterDataSet.java | 75 -
.../query/groupby/MergeGroupByExecutor.java | 143 --
.../query/groupby/RemoteGroupByExecutor.java | 176 --
.../query/last/ClusterLastQueryExecutor.java | 296 ---
.../cluster/query/manage/ClusterQueryManager.java | 129 --
.../query/manage/ClusterSessionManager.java | 138 --
.../cluster/query/manage/QueryCoordinator.java | 66 -
.../cluster/query/reader/ClusterReaderFactory.java | 1229 -----------
.../cluster/query/reader/ClusterTimeGenerator.java | 217 --
.../iotdb/cluster/query/reader/DataSourceInfo.java | 272 ---
.../iotdb/cluster/query/reader/EmptyReader.java | 172 --
.../reader/ManagedDescPriorityMergeReader.java | 96 -
.../query/reader/ManagedPriorityMergeReader.java | 94 -
.../cluster/query/reader/MergedReaderByTime.java | 47 -
.../reader/RemoteSeriesReaderByTimestamp.java | 122 --
.../query/reader/RemoteSimpleSeriesReader.java | 167 --
.../query/reader/mult/AbstractMultPointReader.java | 70 -
.../mult/AssignPathAscPriorityMergeReader.java | 49 -
.../mult/AssignPathDescPriorityMergeReader.java | 49 -
.../reader/mult/AssignPathManagedMergeReader.java | 121 --
.../mult/IAssignPathPriorityMergeReader.java | 47 -
.../query/reader/mult/IMultBatchReader.java | 31 -
.../cluster/query/reader/mult/MultBatchReader.java | 74 -
.../query/reader/mult/MultDataSourceInfo.java | 270 ---
.../cluster/query/reader/mult/MultElement.java | 49 -
.../cluster/query/reader/mult/MultEmptyReader.java | 52 -
.../reader/mult/MultSeriesRawDataPointReader.java | 55 -
.../query/reader/mult/RemoteMultSeriesReader.java | 227 --
.../iotdb/cluster/server/ClusterRPCService.java | 110 -
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 47 -
.../iotdb/cluster/server/HardLinkCleaner.java | 110 -
.../apache/iotdb/cluster/server/NodeCharacter.java | 28 -
.../cluster/server/PullSnapshotHintService.java | 181 --
.../org/apache/iotdb/cluster/server/Response.java | 63 -
.../iotdb/cluster/server/StoppedMemberManager.java | 160 --
.../server/basic/ClusterServiceProvider.java | 95 -
.../server/clusterinfo/ClusterInfoServer.java | 90 -
.../server/clusterinfo/ClusterInfoServerMBean.java | 22 -
.../server/clusterinfo/ClusterInfoServiceImpl.java | 71 -
.../ClusterInfoServiceThriftHandler.java | 55 -
.../handlers/caller/AppendGroupEntryHandler.java | 157 --
.../handlers/caller/AppendNodeEntryHandler.java | 187 --
.../server/handlers/caller/ElectionHandler.java | 167 --
.../server/handlers/caller/GenericHandler.java | 94 -
.../caller/GetChildNodeNextLevelHandler.java | 59 -
.../caller/GetChildNodeNextLevelPathHandler.java | 60 -
.../server/handlers/caller/GetDevicesHandler.java | 60 -
.../handlers/caller/GetNodesListHandler.java | 59 -
.../caller/GetTimeseriesSchemaHandler.java | 59 -
.../server/handlers/caller/HeartbeatHandler.java | 156 --
.../server/handlers/caller/JoinClusterHandler.java | 65 -
.../server/handlers/caller/LogCatchUpHandler.java | 115 -
.../handlers/caller/LogCatchUpInBatchHandler.java | 111 -
.../server/handlers/caller/NodeStatusHandler.java | 59 -
.../handlers/caller/PreviousFillHandler.java | 101 -
.../caller/PullMeasurementSchemaHandler.java | 78 -
.../handlers/caller/PullSnapshotHandler.java | 81 -
.../caller/PullTimeseriesSchemaHandler.java | 73 -
.../handlers/caller/ShowTimeSeriesHandler.java | 121 --
.../handlers/caller/SnapshotCatchUpHandler.java | 61 -
.../server/handlers/caller/package-info.java | 21 -
.../handlers/forwarder/ForwardPlanHandler.java | 68 -
.../server/heartbeat/DataHeartbeatThread.java | 68 -
.../cluster/server/heartbeat/HeartbeatThread.java | 443 ----
.../server/heartbeat/MetaHeartbeatThread.java | 96 -
.../cluster/server/member/DataGroupMember.java | 1164 ----------
.../server/member/DataGroupMemberMBean.java | 25 -
.../cluster/server/member/MetaGroupMember.java | 1954 -----------------
.../server/member/MetaGroupMemberMBean.java | 35 -
.../iotdb/cluster/server/member/RaftMember.java | 2219 --------------------
.../cluster/server/member/RaftMemberMBean.java | 53 -
.../iotdb/cluster/server/member/package-info.java | 24 -
.../iotdb/cluster/server/monitor/NodeReport.java | 268 ---
.../iotdb/cluster/server/monitor/NodeStatus.java | 118 --
.../cluster/server/monitor/NodeStatusManager.java | 183 --
.../apache/iotdb/cluster/server/monitor/Peer.java | 70 -
.../apache/iotdb/cluster/server/monitor/Timer.java | 337 ---
.../server/raft/AbstractDataRaftService.java | 54 -
.../server/raft/AbstractMetaRaftService.java | 52 -
.../cluster/server/raft/AbstractRaftService.java | 76 -
.../server/raft/DataRaftHeartBeatService.java | 62 -
.../server/raft/DataRaftHeartBeatServiceMBean.java | 22 -
.../iotdb/cluster/server/raft/DataRaftService.java | 59 -
.../cluster/server/raft/DataRaftServiceMBean.java | 22 -
.../server/raft/MetaRaftHeartBeatService.java | 62 -
.../server/raft/MetaRaftHeartBeatServiceMBean.java | 22 -
.../iotdb/cluster/server/raft/MetaRaftService.java | 59 -
.../cluster/server/raft/MetaRaftServiceMBean.java | 22 -
.../cluster/server/raft/RaftServiceHandler.java | 43 -
.../cluster/server/service/BaseAsyncService.java | 176 --
.../cluster/server/service/BaseSyncService.java | 181 --
.../cluster/server/service/DataAsyncService.java | 503 -----
.../cluster/server/service/DataGroupEngine.java | 510 -----
.../server/service/DataGroupEngineMBean.java | 31 -
.../server/service/DataGroupServiceImpls.java | 749 -------
.../cluster/server/service/DataSyncService.java | 458 ----
.../cluster/server/service/MetaAsyncService.java | 255 ---
.../cluster/server/service/MetaSyncService.java | 253 ---
.../iotdb/cluster/server/service/package-info.java | 24 -
.../apache/iotdb/cluster/utils/ClientUtils.java | 66 -
.../iotdb/cluster/utils/ClusterConsistent.java | 30 -
.../apache/iotdb/cluster/utils/ClusterNode.java | 86 -
.../iotdb/cluster/utils/ClusterQueryUtils.java | 84 -
.../apache/iotdb/cluster/utils/ClusterUtils.java | 376 ----
.../org/apache/iotdb/cluster/utils/IOUtils.java | 88 -
.../iotdb/cluster/utils/NodeSerializeUtils.java | 92 -
.../apache/iotdb/cluster/utils/PartitionUtils.java | 184 --
.../apache/iotdb/cluster/utils/PlanSerializer.java | 59 -
.../apache/iotdb/cluster/utils/StatusUtils.java | 228 --
.../cluster/utils/nodetool/ClusterMonitor.java | 325 ---
.../utils/nodetool/ClusterMonitorMBean.java | 85 -
.../iotdb/cluster/utils/nodetool/NodeTool.java | 52 -
.../iotdb/cluster/utils/nodetool/Printer.java | 38 -
.../cluster/utils/nodetool/function/Header.java | 60 -
.../cluster/utils/nodetool/function/LogView.java | 88 -
.../cluster/utils/nodetool/function/Migration.java | 59 -
.../utils/nodetool/function/NodeToolCmd.java | 145 --
.../cluster/utils/nodetool/function/Partition.java | 102 -
.../cluster/utils/nodetool/function/Ring.java | 50 -
.../cluster/utils/nodetool/function/Slot.java | 63 -
.../cluster/utils/nodetool/function/Status.java | 63 -
.../iotdb/cluster/client/BaseClientTest.java | 156 --
.../iotdb/cluster/client/ClientManagerTest.java | 212 --
.../cluster/client/ClientPoolFactoryTest.java | 293 ---
.../iotdb/cluster/client/MockClientManager.java | 47 -
.../cluster/client/async/AsyncDataClientTest.java | 79 -
.../cluster/client/async/AsyncMetaClientTest.java | 78 -
.../cluster/client/sync/SyncClientAdaptorTest.java | 464 ----
.../cluster/client/sync/SyncDataClientTest.java | 110 -
.../cluster/client/sync/SyncMetaClientTest.java | 110 -
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 176 --
.../iotdb/cluster/common/TestAsyncClient.java | 53 -
.../iotdb/cluster/common/TestAsyncDataClient.java | 304 ---
.../iotdb/cluster/common/TestAsyncMetaClient.java | 50 -
.../iotdb/cluster/common/TestDataGroupMember.java | 45 -
.../apache/iotdb/cluster/common/TestException.java | 27 -
.../org/apache/iotdb/cluster/common/TestLog.java | 67 -
.../iotdb/cluster/common/TestLogApplier.java | 66 -
.../iotdb/cluster/common/TestLogManager.java | 39 -
.../cluster/common/TestManagedSeriesReader.java | 96 -
.../iotdb/cluster/common/TestMetaGroupMember.java | 39 -
.../cluster/common/TestPartitionedLogManager.java | 54 -
.../apache/iotdb/cluster/common/TestSnapshot.java | 110 -
.../iotdb/cluster/common/TestSyncClient.java | 47 -
.../org/apache/iotdb/cluster/common/TestUtils.java | 439 ----
.../cluster/integration/BaseSingleNodeTest.java | 90 -
.../iotdb/cluster/integration/SingleNodeTest.java | 131 --
.../iotdb/cluster/log/CommitLogCallbackTest.java | 53 -
.../iotdb/cluster/log/CommitLogTaskTest.java | 78 -
.../apache/iotdb/cluster/log/HardStateTest.java | 49 -
.../iotdb/cluster/log/LogDispatcherTest.java | 269 ---
.../apache/iotdb/cluster/log/LogParserTest.java | 122 --
.../log/applier/AsyncDataLogApplierTest.java | 174 --
.../cluster/log/applier/DataLogApplierTest.java | 499 -----
.../cluster/log/applier/MetaLogApplierTest.java | 135 --
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 398 ----
.../cluster/log/catchup/LogCatchUpTaskTest.java | 301 ---
.../log/catchup/SnapshotCatchUpTaskTest.java | 282 ---
.../cluster/log/logtypes/SerializeLogTest.java | 146 --
.../log/manage/CommittedEntryManagerTest.java | 625 ------
.../FilePartitionedSnapshotLogManagerTest.java | 117 --
.../manage/MetaSingleSnapshotLogManagerTest.java | 93 -
.../cluster/log/manage/RaftLogManagerTest.java | 1889 -----------------
.../log/manage/UnCommittedEntryManagerTest.java | 695 ------
.../serializable/SyncLogDequeSerializerTest.java | 612 ------
.../cluster/log/snapshot/DataSnapshotTest.java | 196 --
.../cluster/log/snapshot/FileSnapshotTest.java | 310 ---
.../log/snapshot/MetaSimpleSnapshotTest.java | 346 ---
.../log/snapshot/PartitionedSnapshotTest.java | 204 --
.../snapshot/PullSnapshotTaskDescriptorTest.java | 64 -
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 337 ---
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 132 --
.../cluster/partition/SchemaProcessorWhiteBox.java | 54 -
.../iotdb/cluster/partition/SlotManagerTest.java | 155 --
.../cluster/partition/SlotPartitionTableTest.java | 546 -----
.../apache/iotdb/cluster/query/BaseQueryTest.java | 125 --
.../query/ClusterAggregateExecutorTest.java | 145 --
.../query/ClusterDataQueryExecutorTest.java | 240 ---
.../query/ClusterPhysicalGeneratorTest.java | 72 -
.../cluster/query/ClusterPlanExecutorTest.java | 112 -
.../iotdb/cluster/query/ClusterPlannerTest.java | 55 -
.../cluster/query/ClusterQueryRouterTest.java | 324 ---
.../query/ClusterUDTFQueryExecutorTest.java | 121 --
.../iotdb/cluster/query/LoadConfigurationTest.java | 124 --
.../query/fill/ClusterFillExecutorTest.java | 170 --
.../ClusterGroupByNoVFilterDataSetTest.java | 90 -
.../groupby/ClusterGroupByVFilterDataSetTest.java | 102 -
.../query/groupby/MergeGroupByExecutorTest.java | 117 --
.../query/groupby/RemoteGroupByExecutorTest.java | 171 --
.../query/last/ClusterLastQueryExecutorTest.java | 95 -
.../query/manage/ClusterQueryManagerTest.java | 182 --
.../cluster/query/manage/QueryCoordinatorTest.java | 121 --
.../query/reader/ClusterReaderFactoryTest.java | 85 -
.../query/reader/ClusterTimeGeneratorTest.java | 134 --
.../cluster/query/reader/DatasourceInfoTest.java | 112 -
.../reader/RemoteSeriesReaderByTimestampTest.java | 269 ---
.../query/reader/RemoteSimpleSeriesReaderTest.java | 243 ---
.../mult/AssignPathManagedMergeReaderTest.java | 208 --
.../mult/MultSeriesRawDataPointReaderTest.java | 67 -
.../reader/mult/RemoteMultSeriesReaderTest.java | 346 ---
.../server/clusterinfo/ClusterInfoServerTest.java | 99 -
.../clusterinfo/ClusterInfoServiceImplTest.java | 100 -
.../caller/AppendGroupEntryHandlerTest.java | 188 --
.../caller/AppendNodeEntryHandlerTest.java | 175 --
.../handlers/caller/ElectionHandlerTest.java | 178 --
.../server/handlers/caller/GenericHandlerTest.java | 58 -
.../handlers/caller/HeartbeatHandlerTest.java | 121 --
.../handlers/caller/JoinClusterHandlerTest.java | 67 -
.../handlers/caller/LogCatchUpHandlerTest.java | 128 --
.../caller/PullMeasurementSchemaHandlerTest.java | 92 -
.../handlers/caller/PullSnapshotHandlerTest.java | 84 -
.../caller/SnapshotCatchUpHandlerTest.java | 58 -
.../handlers/forwarder/ForwardPlanHandlerTest.java | 59 -
.../server/heartbeat/DataHeartbeatThreadTest.java | 160 --
.../server/heartbeat/HeartbeatThreadTest.java | 244 ---
.../server/heartbeat/MetaHeartbeatThreadTest.java | 244 ---
.../iotdb/cluster/server/member/BaseMember.java | 328 ---
.../cluster/server/member/DataGroupMemberTest.java | 1255 -----------
.../cluster/server/member/MetaGroupMemberTest.java | 1488 -------------
.../cluster/server/member/RaftMemberTest.java | 246 ---
.../org/apache/iotdb/cluster/utils/Constants.java | 24 -
.../cluster/utils/CreateTemplatePlanUtil.java | 74 -
.../iotdb/cluster/utils/SerializeUtilTest.java | 210 --
cluster/src/test/resources/logback-test.xml | 41 -
.../resources/node1conf/iotdb-cluster.properties | 37 -
.../resources/node1conf/iotdb-engine.properties | 30 -
.../src/test/resources/node1conf/iotdb-metric.yml | 21 -
cluster/src/test/resources/node1conf/logback.xml | 282 ---
.../resources/node2conf/iotdb-cluster.properties | 37 -
.../resources/node2conf/iotdb-engine.properties | 30 -
.../src/test/resources/node2conf/iotdb-metric.yml | 21 -
cluster/src/test/resources/node2conf/logback.xml | 282 ---
.../resources/node3conf/iotdb-cluster.properties | 37 -
.../resources/node3conf/iotdb-engine.properties | 30 -
.../src/test/resources/node3conf/iotdb-metric.yml | 21 -
cluster/src/test/resources/node3conf/logback.xml | 282 ---
.../resources/conf/iotdb-confignode.properties | 10 +-
.../client/SyncConfigNodeClientPool.java | 52 +-
.../confignode/client/SyncDataNodeClientPool.java | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 6 +-
.../consensus/request/ConfigRequest.java | 6 +-
.../consensus/request/ConfigRequestType.java | 2 +-
...LocationsReq.java => GetRegionInfoListReq.java} | 10 +-
...nLocationsResp.java => RegionInfoListResp.java} | 14 +-
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 12 +-
.../iotdb/confignode/manager/ConsensusManager.java | 22 +-
.../manager/{Manager.java => IManager.java} | 6 +-
.../iotdb/confignode/manager/NodeManager.java | 4 +-
.../iotdb/confignode/manager/PartitionManager.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../manager/load/balancer/PartitionBalancer.java | 6 +-
.../manager/load/balancer/RegionBalancer.java | 6 +-
.../manager/load/balancer/RouteBalancer.java | 6 +-
.../partition/GreedyPartitionAllocator.java | 6 +-
.../executor/ConfigRequestExecutor.java | 10 +-
.../persistence/partition/PartitionInfo.java | 46 +-
.../partition/StorageGroupPartitionTable.java | 34 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +-
.../consensus/request/ConfigRequestSerDeTest.java | 24 +-
.../confignode/persistence/PartitionInfoTest.java | 52 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 20 +-
.../confignode1conf/iotdb-confignode.properties | 2 +-
.../confignode2conf/iotdb-confignode.properties | 2 +-
.../confignode3conf/iotdb-confignode.properties | 2 +-
.../iotdb/consensus/config/MultiLeaderConfig.java | 8 +-
.../multileader/MultiLeaderConsensus.java | 2 +-
.../multileader/logdispatcher/LogDispatcher.java | 34 +-
.../multileader/MultiLeaderConsensusTest.java | 47 +-
distribution/src/assembly/all.xml | 4 +-
distribution/src/assembly/server.xml | 4 +-
docker/src/main/Dockerfile-cluster | 44 -
docker/src/main/Dockerfile-single | 2 +-
docker/src/main/Dockerfile-single-influxdb | 4 +-
docker/src/main/Dockerfile-single-tc | 2 +-
docs/Development/ContributeGuide.md | 14 -
docs/Development/HowtoContributeCode.md | 4 +-
docs/UserGuide/API/Programming-MQTT.md | 8 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 8 +-
docs/UserGuide/Data-Concept/Data-Type.md | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 2 +-
docs/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 6 +-
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 4 +-
docs/UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 28 +-
docs/UserGuide/Process-Data/Triggers.md | 2 +-
.../Process-Data/UDF-User-Defined-Function.md | 2 +-
docs/UserGuide/QuickStart/QuickStart.md | 10 +-
docs/UserGuide/QuickStart/ServerFileList.md | 4 +-
docs/UserGuide/Reference/Config-Manual.md | 8 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +-
docs/zh/Development/HowtoContributeCode.md | 4 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 6 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 12 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 6 +-
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 6 +-
.../UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 30 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 2 +-
.../Process-Data/UDF-User-Defined-Function.md | 2 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 4 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 4 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 14 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +-
example/mqtt-customize/README.md | 4 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
example/mqtt/README.md | 2 +-
integration-test/pom.xml | 4 +-
integration-test/src/assembly/mpp-test.xml | 4 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 2 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 14 +-
.../db/it/alignbydevice}/IoTDBAlignByDeviceIT.java | 196 +-
integration/pom.xml | 5 -
.../apache/iotdb/integration/env/ClusterNode.java | 4 +-
.../apache/iotdb/commons/client/ClientManager.java | 2 +-
...AsyncDataNodeMPPDataExchangeServiceClient.java} | 26 +-
... SyncDataNodeMPPDataExchangeServiceClient.java} | 28 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/partition/SerializeTest.java | 4 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 8 +-
pom.xml | 6 +-
schema-engine-rocksdb/README.md | 2 +-
.../resources/conf/schema-rocksdb.properties | 8 +-
.../conf/{iotdb-env.bat => datanode-env.bat} | 2 +-
.../conf/{iotdb-env.sh => datanode-env.sh} | 2 +-
...engine.properties => iotdb-datanode.properties} | 12 +-
.../src/assembly/resources/sbin/start-datanode.bat | 14 +-
.../src/assembly/resources/sbin/start-datanode.sh | 14 +-
.../assembly/resources/sbin/start-new-server.bat | 6 +-
.../assembly/resources/sbin/start-new-server.sh | 8 +-
.../src/assembly/resources/sbin/start-server.bat | 6 +-
server/src/assembly/resources/sbin/start-server.sh | 8 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 4 +-
server/src/assembly/resources/sbin/stop-server.bat | 4 +-
server/src/assembly/resources/sbin/stop-server.sh | 2 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 6 +-
.../assembly/resources/tools/rocksdb-transfer.sh | 8 +-
.../assembly/resources/tools/start-WalChecker.sh | 6 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 30 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 56 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 24 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 5 +
.../metadata/SeriesOverflowException.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 4 +-
.../exception/sql/PathNumOverLimitException.java | 3 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 6 +-
.../datatransfer/DataBlockServiceMBean.java | 34 -
.../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 2 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 2 +-
.../db/mpp/execution/driver/SchemaDriver.java | 2 +-
.../IMPPDataExchangeManager.java} | 8 +-
.../IMPPDataExchangeManagerCallback.java} | 4 +-
.../{datatransfer => exchange}/ISinkHandle.java | 2 +-
.../{datatransfer => exchange}/ISourceHandle.java | 2 +-
.../LocalSinkHandle.java | 4 +-
.../LocalSourceHandle.java | 6 +-
.../MPPDataExchangeManager.java} | 65 +-
.../MPPDataExchangeService.java} | 61 +-
.../exchange/MPPDataExchangeServiceMBean.java | 5 +-
.../MPPDataExchangeServiceThriftHandler.java} | 4 +-
.../SharedTsBlockQueue.java | 2 +-
.../{datatransfer => exchange}/SinkHandle.java | 25 +-
.../{datatransfer => exchange}/SourceHandle.java | 25 +-
.../TsBlockSerdeFactory.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../execution/operator/process/FilterOperator.java | 10 +-
.../operator/process/TransformOperator.java | 23 +
.../operator/source/ExchangeOperator.java | 2 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 10 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 2 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 344 +--
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 32 +-
.../db/mpp/plan/constant/DataNodeEndPoints.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 14 +-
.../mpp/plan/execution/config/ShowRegionTask.java | 23 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 23 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 4 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../SimpleFragmentParallelPlanner.java | 4 +-
.../crud/InsertMultiTabletsStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 38 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 2 +-
.../LocalSinkHandleTest.java | 10 +-
.../LocalSourceHandleTest.java | 4 +-
.../MPPDataExchangeManagerTest.java} | 32 +-
.../SharedTsBlockQueueTest.java | 24 +-
.../{datatransfer => exchange}/SinkHandleTest.java | 42 +-
.../SourceHandleTest.java | 51 +-
.../{datatransfer => exchange}/StubSinkHandle.java | 2 +-
.../{datatransfer => exchange}/Utils.java | 2 +-
.../schedule/DefaultDriverSchedulerTest.java | 36 +-
.../execution/schedule/DriverSchedulerTest.java | 13 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 8 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 4 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 6 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 8 +-
.../iotdb/db/service/InternalServiceImplTest.java | 6 +-
...engine.properties => iotdb-datanode.properties} | 4 +-
...engine.properties => iotdb-datanode.properties} | 4 +-
...engine.properties => iotdb-datanode.properties} | 4 +-
...engine.properties => iotdb-datanode.properties} | 4 +-
testcontainer/Readme.md | 8 +-
testcontainer/pom.xml | 26 -
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 4 +-
.../src/test/resources/1node/docker-compose.yaml | 44 -
.../test/resources/1node/iotdb-cluster.properties | 35 -
.../src/test/resources/3nodes/docker-compose.yaml | 44 -
.../test/resources/3nodes/iotdb-cluster.properties | 35 -
.../src/test/resources/5nodes/docker-compose.yaml | 43 -
.../test/resources/5nodes/iotdb-cluster.properties | 35 -
...engine.properties => iotdb-datanode.properties} | 2 +-
thrift-cluster/README.md | 22 -
thrift-cluster/pom.xml | 72 -
thrift-cluster/rpc-changelist.md | 181 --
thrift-cluster/src/main/thrift/cluster.thrift | 584 ------
thrift-commons/src/main/thrift/common.thrift | 14 +-
.../src/main/thrift/confignode.thrift | 2 +-
thrift/src/main/thrift/mpp.thrift | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
578 files changed, 1266 insertions(+), 70535 deletions(-)
delete mode 100644 cluster/pom.xml
delete mode 100644 cluster/src/assembly/cluster.xml
delete mode 100644 cluster/src/assembly/resources/conf/iotdb-cluster.properties
delete mode 100755 cluster/src/assembly/resources/sbin/add-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/add-node.sh
delete mode 100755 cluster/src/assembly/resources/sbin/nodetool.bat
delete mode 100755 cluster/src/assembly/resources/sbin/nodetool.sh
delete mode 100755 cluster/src/assembly/resources/sbin/remove-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/remove-node.sh
delete mode 100755 cluster/src/assembly/resources/sbin/start-node.bat
delete mode 100755 cluster/src/assembly/resources/sbin/start-node.sh
delete mode 100644 cluster/src/assembly/resources/sbin/stop-node.bat
delete mode 100644 cluster/src/assembly/resources/sbin/stop-node.sh
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClusterFileFlushPolicy.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBServerCommandLine.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/RemoteTsFileResource.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/BaseFactory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/ClientCategory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/ClientManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/ClientPoolFactory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/IClientManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncBaseFactory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncDataClient.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/async/AsyncMetaClient.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConfig.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterConstant.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/config/ClusterDescriptor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/config/ConsistencyLevel.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/AddSelfException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/ChangeMembershipException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/CheckConsistencyException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/EmptyIntervalException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryCompactedException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/EntryUnavailableException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/GetEntriesWrongParametersException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/MemberReadOnlyException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/NotInSameGroupException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/NotManagedSlotException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/PartitionTableUnavailableException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/PullFileException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/QueryTimeOutException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/RequestTimeOutException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/SnapshotInstallationException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/StartUpCheckFailureException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/UnknownLogTypeException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/exception/UnsupportedPlanException.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogTask.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/HardState.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/Log.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/LogApplier.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/LogParser.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/Snapshot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/StableEntryManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplier.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/applier/BaseApplier.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/applier/DataLogApplier.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/applier/MetaLogApplier.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/CatchUpTask.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTask.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTask.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/AddNodeLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/CloseFileLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/EmptyContentLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/LargeTestLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/PhysicalPlanLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/RemoveNodeLog.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/PartitionedSnapshotLogManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogManagerMeta.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTask.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotInstaller.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/metadata/CSchemaProcessor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/metadata/MetaPuller.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeAdditionResult.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/NodeRemovalResult.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionGroup.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionTable.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/DefaultSlotBalancer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/SlotBalancer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeAdditionResult.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotNodeRemovalResult.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotStrategy.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotTimePartitionFilter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPhysicalGenerator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanRouter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterQueryRouter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregateExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/aggregate/ClusterAggregator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterLinearFill.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/fill/ClusterPreviousFill.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/fill/PreviousFillArguments.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotSgFilter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotTsFileFilter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSet.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSet.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterSessionManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/manage/QueryCoordinator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactory.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGenerator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/DataSourceInfo.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/EmptyReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedDescPriorityMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ManagedPriorityMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/MergedReaderByTime.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestamp.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AbstractMultPointReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathAscPriorityMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathDescPriorityMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IAssignPathPriorityMergeReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IMultBatchReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultBatchReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultDataSourceInfo.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultElement.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultEmptyReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReader.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterTSServiceImpl.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/HardLinkCleaner.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/NodeCharacter.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/PullSnapshotHintService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/Response.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/StoppedMemberManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/basic/ClusterServiceProvider.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImpl.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelPathHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetDevicesHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetNodesListHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetTimeseriesSchemaHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpInBatchHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/NodeStatusHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PreviousFillHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PullTimeseriesSchemaHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/ShowTimeSeriesHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMemberMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMemberMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeReport.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatus.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/NodeStatusManager.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Peer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractDataRaftService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractMetaRaftService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/AbstractRaftService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseAsyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/BaseSyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataAsyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngine.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngineMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataSyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaAsyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/package-info.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClientUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterConsistent.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterNode.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterQueryUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/ClusterUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/IOUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/NodeSerializeUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/PartitionUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/StatusUtils.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitor.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitorMBean.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/NodeTool.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/Printer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Header.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/LogView.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Migration.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/NodeToolCmd.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Partition.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Ring.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Slot.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Status.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/BaseClientTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/ClientManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/ClientPoolFactoryTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/MockClientManager.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncDataClientTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaClientTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncDataClientTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncMetaClientTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/IoTDBTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncClient.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncDataClient.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestAsyncMetaClient.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestDataGroupMember.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestLog.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogApplier.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestManagedSeriesReader.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestMetaGroupMember.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestPartitionedLogManager.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestSnapshot.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestSyncClient.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/TestUtils.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/integration/BaseSingleNodeTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/integration/SingleNodeTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogTaskTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/HardStateTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/LogDispatcherTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/LogParserTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/applier/AsyncDataLogApplierTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/CatchUpTaskTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTaskTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTaskTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/logtypes/SerializeLogTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/MetaSingleSnapshotLogManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/FileSnapshotTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshotTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PartitionedSnapshotTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskDescriptorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/PullSnapshotTaskTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/SimpleSnapshot.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/partition/SchemaProcessorWhiteBox.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/partition/SlotPartitionTableTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/BaseQueryTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterAggregateExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterDataQueryExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPhysicalGeneratorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlanExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPlannerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/fill/ClusterFillExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSetTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSetTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManagerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/manage/QueryCoordinatorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactoryTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterTimeGeneratorTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSeriesReaderByTimestampTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReaderTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImplTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/GenericHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/JoinClusterHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/LogCatchUpHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullMeasurementSchemaHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/PullSnapshotHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardPlanHandlerTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThreadTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThreadTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThreadTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/member/BaseMember.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/member/DataGroupMemberTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/member/MetaGroupMemberTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/member/RaftMemberTest.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/utils/CreateTemplatePlanUtil.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/utils/SerializeUtilTest.java
delete mode 100644 cluster/src/test/resources/logback-test.xml
delete mode 100644
cluster/src/test/resources/node1conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node1conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node1conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node1conf/logback.xml
delete mode 100644
cluster/src/test/resources/node2conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node2conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node2conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node2conf/logback.xml
delete mode 100644
cluster/src/test/resources/node3conf/iotdb-cluster.properties
delete mode 100644 cluster/src/test/resources/node3conf/iotdb-engine.properties
delete mode 100644 cluster/src/test/resources/node3conf/iotdb-metric.yml
delete mode 100644 cluster/src/test/resources/node3conf/logback.xml
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetRegionLocationsReq.java
=> GetRegionInfoListReq.java} (87%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{RegionLocationsResp.java
=> RegionInfoListResp.java} (76%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{Manager.java =>
IManager.java} (98%)
delete mode 100644 docker/src/main/Dockerfile-cluster
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice}/IoTDBAlignByDeviceIT.java
(88%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncDataNodeDataBlockServiceClient.java
=> AsyncDataNodeMPPDataExchangeServiceClient.java} (77%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncDataNodeDataBlockServiceClient.java
=> SyncDataNodeMPPDataExchangeServiceClient.java} (76%)
rename server/src/assembly/resources/conf/{iotdb-env.bat => datanode-env.bat}
(98%)
rename server/src/assembly/resources/conf/{iotdb-env.sh => datanode-env.sh}
(99%)
rename server/src/assembly/resources/conf/{iotdb-engine.properties =>
iotdb-datanode.properties} (99%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockServiceMBean.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer/IDataBlockManager.java
=> exchange/IMPPDataExchangeManager.java} (93%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer/IDataBlockManagerCallback.java
=> exchange/IMPPDataExchangeManagerCallback.java} (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/ISinkHandle.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/ISourceHandle.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/LocalSinkHandle.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/LocalSourceHandle.java (95%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer/DataBlockManager.java
=> exchange/MPPDataExchangeManager.java} (89%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer/DataBlockService.java
=> exchange/MPPDataExchangeService.java} (63%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/server/ClusterRPCServiceMBean.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeServiceMBean.java
(91%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer/DataBlockServiceThriftHandler.java
=> exchange/MPPDataExchangeServiceThriftHandler.java} (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SharedTsBlockQueue.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SinkHandle.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SourceHandle.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/TsBlockSerdeFactory.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/LocalSinkHandleTest.java (94%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/LocalSourceHandleTest.java (97%)
rename
server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer/DataBlockManagerTest.java
=> exchange/MPPDataExchangeManagerTest.java} (81%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SharedTsBlockQueueTest.java (91%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SinkHandleTest.java (93%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/SourceHandleTest.java (93%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/StubSinkHandle.java (97%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/{datatransfer =>
exchange}/Utils.java (98%)
rename server/src/test/resources/datanode1conf/{iotdb-engine.properties =>
iotdb-datanode.properties} (94%)
rename server/src/test/resources/datanode2conf/{iotdb-engine.properties =>
iotdb-datanode.properties} (94%)
rename server/src/test/resources/datanode3conf/{iotdb-engine.properties =>
iotdb-datanode.properties} (94%)
rename server/src/test/resources/{iotdb-engine.properties =>
iotdb-datanode.properties} (95%)
delete mode 100644 testcontainer/src/test/resources/1node/docker-compose.yaml
delete mode 100644
testcontainer/src/test/resources/1node/iotdb-cluster.properties
delete mode 100644 testcontainer/src/test/resources/3nodes/docker-compose.yaml
delete mode 100644
testcontainer/src/test/resources/3nodes/iotdb-cluster.properties
delete mode 100644 testcontainer/src/test/resources/5nodes/docker-compose.yaml
delete mode 100644
testcontainer/src/test/resources/5nodes/iotdb-cluster.properties
rename testcontainer/src/test/resources/{iotdb-engine.properties =>
iotdb-datanode.properties} (94%)
delete mode 100644 thrift-cluster/README.md
delete mode 100644 thrift-cluster/pom.xml
delete mode 100644 thrift-cluster/rpc-changelist.md
delete mode 100644 thrift-cluster/src/main/thrift/cluster.thrift
