This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6357533a25c [IOTDB-6125] Fix DataPartition allocation bug when insert
big batch data (#10924)
add e891a5d1f31 [IOTDB-6121] Consensus layer interface and exception
handling refactoring (#10896)
No new revisions were added by this update.
Summary of changes:
.../confignode/manager/ClusterQuotaManager.java | 52 ++--
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../iotdb/confignode/manager/ModelManager.java | 75 +++---
.../confignode/manager/PermissionManager.java | 39 ++-
.../iotdb/confignode/manager/TriggerManager.java | 56 ++--
.../iotdb/confignode/manager/UDFManager.java | 28 +-
.../manager/consensus/ConsensusManager.java | 84 +++---
.../iotdb/confignode/manager/cq/CQManager.java | 42 ++-
.../confignode/manager/cq/CQScheduleTask.java | 26 +-
.../iotdb/confignode/manager/node/NodeManager.java | 73 +++--
.../manager/partition/PartitionManager.java | 187 +++++++++----
.../manager/pipe/plugin/PipePluginCoordinator.java | 23 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 14 +-
.../manager/schema/ClusterSchemaManager.java | 276 ++++++++++++++++---
.../procedure/env/ConfigNodeProcedureEnv.java | 18 +-
.../procedure/env/DataNodeRemoveHandler.java | 7 +-
.../procedure/impl/cq/CreateCQProcedure.java | 113 ++++----
.../procedure/impl/model/CreateModelProcedure.java | 18 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 27 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 13 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 19 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 23 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 42 ++-
.../impl/pipe/task/DropPipeProcedureV2.java | 18 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 42 ++-
.../impl/pipe/task/StopPipeProcedureV2.java | 42 ++-
.../impl/schema/DeleteDatabaseProcedure.java | 3 +-
.../impl/schema/SetTemplateProcedure.java | 77 ++++--
.../statemachine/CreateRegionGroupsProcedure.java | 7 +-
.../impl/trigger/CreateTriggerProcedure.java | 22 +-
.../procedure/store/ConfigProcedureStore.java | 13 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +-
iotdb-core/consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/IConsensus.java | 166 +++++++-----
.../iotdb/consensus/common/ConsensusGroup.java | 1 -
.../org/apache/iotdb/consensus/common/Peer.java | 1 -
.../org/apache/iotdb/consensus/common/Utils.java | 13 +-
.../common/request/ByteBufferConsensusRequest.java | 12 +-
.../common/response/ConsensusGenericResponse.java | 64 -----
.../common/response/ConsensusReadResponse.java | 69 -----
.../common/response/ConsensusResponse.java | 39 ---
.../common/response/ConsensusWriteResponse.java | 82 ------
.../iotdb/consensus/config/ConsensusConfig.java | 18 +-
.../consensus/exception/NodeReadOnlyException.java | 31 ---
.../PeerNotInConsensusGroupException.java | 6 +-
.../exception/RatisUnderRecoveryException.java | 3 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 222 +++++++--------
.../iotdb/consensus/ratis/RatisConsensus.java | 248 +++++++----------
.../iotdb/consensus/simple/SimpleConsensus.java | 142 +++++-----
...verImpl.java => SimpleConsensusServerImpl.java} | 4 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 18 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 106 ++++++--
.../iotdb/consensus/ratis/RatisConsensusTest.java | 130 +++++----
.../iotdb/consensus/ratis/RecoverReadTest.java | 49 ++--
.../apache/iotdb/consensus/ratis/TestUtils.java | 18 +-
.../iotdb/consensus/simple/RecoveryTest.java | 22 +-
.../consensus/simple/SimpleConsensusTest.java | 228 ++++++++--------
.../db/consensus/DataRegionConsensusImpl.java | 299 ++++++++++-----------
.../db/consensus/SchemaRegionConsensusImpl.java | 216 ++++++++-------
.../iotdb/db/protocol/client/ConfigNodeClient.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 124 +++++----
.../thrift/impl/DataNodeRegionManager.java | 47 ++--
.../execution/executor/RegionReadExecutor.java | 18 +-
.../execution/executor/RegionWriteExecutor.java | 104 +++----
.../template/ClusterTemplateManager.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 12 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 25 +-
.../iotdb/db/service/RegionMigrateService.java | 101 +++----
.../execution/executor/RegionReadExecutorTest.java | 31 +--
.../executor/RegionWriteExecutorTest.java | 24 +-
.../DataNodeInternalRPCServiceImplTest.java | 8 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 38 ++-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
iotdb-protocol/pom.xml | 2 +-
.../pom.xml | 4 +-
.../src/main/thrift/iotconsensus.thrift | 0
pom.xml | 2 +-
78 files changed, 2246 insertions(+), 2022 deletions(-)
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusGenericResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusReadResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusWriteResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/NodeReadOnlyException.java
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/simple/{SimpleServerImpl.java
=> SimpleConsensusServerImpl.java} (94%)
rename iotdb-protocol/{thrift-iot-consensus => thrift-consensus}/pom.xml (95%)
rename iotdb-protocol/{thrift-iot-consensus =>
thrift-consensus}/src/main/thrift/iotconsensus.thrift (100%)
