You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/11/26 07:51:17 UTC
[iotdb] branch master updated (51e3a9c99a -> 8d153466b1)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 51e3a9c99a [IOTDB-4945] Retry with sleep to avoid failure in connecting confignodes caused by Ratis election
add 8d153466b1 Rename MultiLeader to IoTConsensus (#8181)
No new revisions were added by this update.
Summary of changes:
RELEASE_NOTES.md | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 14 +--
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../manager/load/balancer/RouteBalancer.java | 45 ++++----
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 12 +--
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-common.properties | 2 +-
consensus/pom.xml | 2 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
...sensusRequest.java => IoTConsensusRequest.java} | 12 +--
.../iotdb/consensus/config/ConsensusConfig.java | 20 ++--
...tiLeaderConfig.java => IoTConsensusConfig.java} | 8 +-
.../IoTConsensus.java} | 96 ++++++++---------
.../IoTConsensusServerImpl.java} | 117 +++++++++++----------
.../IoTConsensusServerMetrics.java} | 28 ++---
.../client/AsyncIoTConsensusServiceClient.java} | 27 ++---
.../client/DispatchLogHandler.java | 10 +-
.../client/IoTConsensusClientPool.java} | 45 ++++----
.../client/SyncIoTConsensusServiceClient.java} | 32 +++---
.../logdispatcher/IndexController.java | 2 +-
.../logdispatcher/IoTConsensusMemoryManager.java} | 14 +--
.../IoTConsensusMemoryManagerMetrics.java} | 18 ++--
.../logdispatcher/LogDispatcher.java | 52 ++++-----
.../logdispatcher/LogDispatcherThreadMetrics.java | 10 +-
.../logdispatcher/PendingBatch.java | 10 +-
.../logdispatcher/SyncStatus.java | 18 ++--
.../service/IoTConsensusRPCService.java} | 32 +++---
.../service/IoTConsensusRPCServiceHandler.java} | 8 +-
.../service/IoTConsensusRPCServiceMBean.java} | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java} | 76 ++++++-------
.../snapshot/SnapshotFragment.java | 4 +-
.../snapshot/SnapshotFragmentReader.java | 2 +-
.../wal/ConsensusReqReader.java | 2 +-
.../wal/GetConsensusReqReaderPlan.java | 2 +-
.../IoTConsensusTest.java} | 20 ++--
.../{multileader => iot}/RecoveryTest.java | 8 +-
.../logdispatcher/IndexControllerTest.java | 2 +-
.../logdispatcher/SyncStatusTest.java | 18 ++--
.../util/FakeConsensusReqReader.java | 4 +-
.../{multileader => iot}/util/RequestSets.java | 2 +-
.../{multileader => iot}/util/TestEntry.java | 6 +-
.../util/TestStateMachine.java | 6 +-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 20 ++--
.../java/org/apache/iotdb/it/env/MppConfig.java | 6 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 4 +-
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 11 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 3 +-
.../resources/conf/iotdb-common.properties | 18 ++--
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +-
pom.xml | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../db/consensus/DataRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 8 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 4 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 ++---
.../db/mpp/plan/parser/StatementGenerator.java | 4 +
.../plan/planner/plan/node/write/InsertNode.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 16 +--
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 8 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 +-
.../pom.xml | 2 +-
.../src/main/thrift/iotconsensus.thrift | 4 +-
74 files changed, 497 insertions(+), 503 deletions(-)
rename consensus/src/main/java/org/apache/iotdb/consensus/common/request/{MultiLeaderConsensusRequest.java => IoTConsensusRequest.java} (69%)
rename consensus/src/main/java/org/apache/iotdb/consensus/config/{MultiLeaderConfig.java => IoTConsensusConfig.java} (98%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensus.java => iot/IoTConsensus.java} (78%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerImpl.java => iot/IoTConsensusServerImpl.java} (87%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerMetrics.java => iot/IoTConsensusServerMetrics.java} (79%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/AsyncMultiLeaderServiceClient.java => iot/client/AsyncIoTConsensusServiceClient.java} (79%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/client/DispatchLogHandler.java (92%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/MultiLeaderConsensusClientPool.java => iot/client/IoTConsensusClientPool.java} (61%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/SyncMultiLeaderServiceClient.java => iot/client/SyncIoTConsensusServiceClient.java} (78%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/IndexController.java (98%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManager.java => iot/logdispatcher/IoTConsensusMemoryManager.java} (85%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java => iot/logdispatcher/IoTConsensusMemoryManagerMetrics.java} (74%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/LogDispatcher.java (91%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/LogDispatcherThreadMetrics.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/PendingBatch.java (90%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/SyncStatus.java (84%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCService.java => iot/service/IoTConsensusRPCService.java} (71%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceHandler.java => iot/service/IoTConsensusRPCServiceHandler.java} (84%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceMBean.java => iot/service/IoTConsensusRPCServiceMBean.java} (88%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceProcessor.java => iot/service/IoTConsensusRPCServiceProcessor.java} (81%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/snapshot/SnapshotFragment.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/snapshot/SnapshotFragmentReader.java (97%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/wal/ConsensusReqReader.java (98%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/wal/GetConsensusReqReaderPlan.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensusTest.java => iot/IoTConsensusTest.java} (94%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/RecoveryTest.java (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/IndexControllerTest.java (98%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/SyncStatusTest.java (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/FakeConsensusReqReader.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/RequestSets.java (96%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/TestEntry.java (91%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/TestStateMachine.java (95%)
rename {thrift-multi-leader-consensus => thrift-iot-consensus}/pom.xml (97%)
rename thrift-multi-leader-consensus/src/main/thrift/mutlileader.thrift => thrift-iot-consensus/src/main/thrift/iotconsensus.thrift (97%)