This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch change_target_config_nodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 15a47bc502 update it
add 2bfd38bfaf fix thrift
add 1b5347dcd4 fix login check. (#6534)
add 71a43a524e [IOTDB-3648] Reinforce ConfigNode startup process (#6524)
add 897ed48ec9 [IOTDB-3247] Recover aligned sensors after deleting
timeseries, query lost data (#6468)
add 558c532083 [IOTDB-3556] Maintain onlineConfigNodes by LoadManager
(#6532)
add deb9732b43 Fix the issues in MultiLeader log dispatcher (#6484)
add b8efd24d10 fixed grafana plugin workflow failed (#6550)
add e3de551a76 fix startup
No new revisions were added by this update.
Summary of changes:
.../client/SyncConfigNodeClientPool.java | 29 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 27 +-
.../confignode/conf/ConfigNodeDescriptor.java | 12 +
.../confignode/conf/ConfigNodeStartupCheck.java | 328 +--------------------
.../confignode/conf/SystemPropertiesUtils.java | 270 +++++++++++++++++
.../statemachine/PartitionRegionStateMachine.java | 2 +-
...tExistsException.java => AddPeerException.java} | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 4 +-
.../iotdb/confignode/manager/ConsensusManager.java | 84 +++---
.../iotdb/confignode/manager/NodeManager.java | 42 +--
.../iotdb/confignode/manager/UDFManager.java | 10 +-
.../iotdb/confignode/manager/load/LoadManager.java | 23 +-
.../iotdb/confignode/persistence/NodeInfo.java | 58 ++--
.../persistence/executor/ConfigPlanExecutor.java | 4 +-
.../persistence/partition/PartitionInfo.java | 2 +-
.../partition/StorageGroupPartitionTable.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 40 ++-
.../procedure/impl/AddConfigNodeProcedure.java | 9 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 193 ++++++++----
.../confignode/service/ConfigNodeCommandLine.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 20 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 24 +-
.../PeerAlreadyInConsensusGroupException.java | 2 +-
.../multileader/MultiLeaderServerImpl.java | 42 ++-
.../client/AsyncMultiLeaderServiceClient.java | 3 +-
.../multileader/logdispatcher/IndexController.java | 67 +++--
.../multileader/logdispatcher/LogDispatcher.java | 80 +++--
.../multileader/service/MultiLeaderRPCService.java | 2 +-
.../multileader/wal/ConsensusReqReader.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 4 +-
.../multileader/MultiLeaderConsensusTest.java | 209 ++-----------
.../iotdb/consensus/multileader/RecoveryTest.java | 4 +-
.../logdispatcher/IndexControllerTest.java | 38 +--
.../multileader/logdispatcher/SyncStatusTest.java | 8 +-
.../multileader/util/FakeConsensusReqReader.java | 111 +++++++
.../consensus/multileader/util/RequestSets.java | 42 +--
.../consensus/multileader/util/TestEntry.java | 60 ++--
.../multileader/util/TestStateMachine.java | 93 ++++++
grafana-plugin/backend-compile.sh | 1 -
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 3 +-
.../async/AsyncDataNodeInternalServiceClient.java | 3 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 3 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 2 +-
.../sync/SyncDataNodeInternalServiceClient.java | 2 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 2 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 2 +-
.../client/mock/MockInternalRPCService.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 35 ++-
.../engine/memtable/AlignedWritableMemChunk.java | 26 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 4 +-
.../planner/plan/node/process/ExchangeNode.java | 6 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 6 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 3 +-
.../iotdb/db/query/control/SessionManager.java | 3 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../thrift/impl/DataNodeRPCServiceImpl.java | 8 +-
.../db/service/thrift/impl/TSServiceImpl.java | 2 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 15 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 5 +
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 3 +
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 5 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 66 ++---
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 40 +--
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 303 +++++++++++++++++++
.../apache/iotdb/session/SessionConnection.java | 2 +-
.../apache/iotdb/session/util/SessionUtils.java | 2 +-
thrift-commons/src/main/thrift/common.thrift | 2 +-
.../src/main/thrift/confignode.thrift | 2 +
74 files changed, 1545 insertions(+), 1006 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/exception/{StorageGroupNotExistsException.java
=> AddPeerException.java} (76%)
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/FakeConsensusReqReader.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/DeletePartitionPlan.java
=>
consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/RequestSets.java
(50%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/StringLiteral.java
=>
consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestEntry.java
(52%)
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
