This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch IOTDB-3883 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1605762a0153987aa0af218e7a3b896998ca547e Merge: 9a6f0bad93 d4b41bbb71 Author: Minghui Liu <[email protected]> AuthorDate: Fri Jul 22 17:17:03 2022 +0800 Merge remote-tracking branch 'origin/master' into IOTDB-3883 .../confignode/client/DataNodeRequestType.java | 3 +- .../async/datanode/AsyncDataNodeClientPool.java | 221 +++--- .../async/handlers/AbstractRetryHandler.java | 33 +- .../client/async/handlers/CreateRegionHandler.java | 14 +- .../client/async/handlers/FlushHandler.java | 16 +- .../async/handlers/FunctionManagementHandler.java | 11 +- .../client/async/handlers/SetTTLHandler.java | 7 +- .../handlers/UpdateRegionRouteMapHandler.java | 9 +- .../request/write/RemoveDataNodePlan.java | 124 +--- .../statemachine/PartitionRegionStateMachine.java | 2 - .../confignode/manager/ClusterSchemaManager.java | 30 +- .../iotdb/confignode/manager/ConfigManager.java | 10 +- .../confignode/manager/DataNodeRemoveManager.java | 806 --------------------- .../apache/iotdb/confignode/manager/IManager.java | 6 +- .../iotdb/confignode/manager/NodeManager.java | 71 +- .../iotdb/confignode/manager/ProcedureManager.java | 34 + .../iotdb/confignode/manager/UDFManager.java | 63 +- .../iotdb/confignode/manager/load/LoadManager.java | 31 +- .../iotdb/confignode/persistence/NodeInfo.java | 204 +----- .../persistence/partition/PartitionInfo.java | 2 +- .../procedure/env/ConfigNodeProcedureEnv.java | 26 +- .../procedure/env/DataNodeRemoveHandler.java | 381 ++++++++++ .../procedure/impl/AbstractNodeProcedure.java | 64 ++ .../procedure/impl/AddConfigNodeProcedure.java | 33 +- .../procedure/impl/RegionMigrateProcedure.java | 230 ++++++ .../procedure/impl/RemoveConfigNodeProcedure.java | 33 +- .../procedure/impl/RemoveDataNodeProcedure.java | 184 +++++ .../confignode/procedure/scheduler/LockQueue.java | 63 ++ .../state/RegionTransitionState.java} | 21 +- .../state/RemoveDataNodeState.java} | 22 +- .../procedure/store/ProcedureFactory.java | 14 + .../iotdb/confignode/service/ConfigNode.java | 27 - .../confignode/service/ConfigNodeCommandLine.java | 31 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 2 +- .../request/write/RemoveDataNodePlanTest.java | 1 - .../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 122 ++++ .../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +- .../db/integration/IoTDBInsertWithoutTimeIT.java | 131 ---- .../commons/partition/DataPartitionQueryParam.java | 14 - pom.xml | 2 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 47 +- .../mpp/plan/analyze/ClusterPartitionFetcher.java | 63 +- .../db/mpp/plan/analyze/cache/PartitionCache.java | 166 +++-- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 15 +- .../plan/planner/distribution/SourceRewriter.java | 19 + .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 15 +- .../java/org/apache/iotdb/db/service/DataNode.java | 105 --- .../db/service/DataNodeServerCommandLine.java | 120 ++- .../iotdb/db/service/RegionMigrateService.java | 15 +- .../mpp/plan/analyze/cache/PartitionCacheTest.java | 432 +++++++++++ 50 files changed, 2189 insertions(+), 1918 deletions(-)
