This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch IOTDB-4619
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ef7b00713b Fix CI
add 43cbe3a2b8 [IOTDB-4631] [IOTDB-4777] Fixed the bug of concurrent
DataNode deletion (#7744)
add fb1e23b574 [IOTDB-4633] Fix bugs of longToBytes in BytesUtils of
tsfile (#7669)
add 4320baa030 [RatisConsensus] fix snapshot param mistake
add a78085d313 [IOTDB-4644] Support modifying DataNode's RPC IP:Port
(#7620)
add d9518672d1 Resolve conflicts
No new revisions were added by this update.
Summary of changes:
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
...erDataNodePlan.java => UpdateDataNodePlan.java} | 30 ++---
.../consensus/response/DataNodeRegisterResp.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 25 +++-
.../apache/iotdb/confignode/manager/IManager.java | 9 ++
.../iotdb/confignode/manager/TriggerManager.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 61 +++++++--
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../confignode/persistence/node/NodeInfo.java | 22 ++-
.../iotdb/confignode/procedure/Procedure.java | 6 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 12 +-
.../procedure/env/DataNodeRemoveHandler.java | 26 ++--
.../impl/node/RemoveDataNodeProcedure.java | 12 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../procedure/state/RemoveDataNodeState.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 26 +++-
.../request/ConfigPhysicalPlanSerDeTest.java | 17 +++
integration-test/checkstyle.xml | 2 +-
integration-test/import-control.xml | 1 +
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 20 ++-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 20 +++
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 42 +++++-
.../confignode/it/IoTDBClusterPartitionIT.java | 19 +--
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 148 ++++++++++++++++++++-
.../iotdb/confignode/it/IoTDBConfigNodeIT.java | 61 +--------
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 17 +--
.../confignode/it/utils/ConfigNodeTestUtils.java | 115 ++++++++++++++++
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +++
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 101 ++++++++++++++
.../java/org/apache/iotdb/db/service/DataNode.java | 21 +--
.../db/service/DataNodeServerCommandLine.java | 10 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../src/main/thrift/confignode.thrift | 13 ++
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 47 +++++++
39 files changed, 758 insertions(+), 179 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/datanode/{RegisterDataNodePlan.java
=> UpdateDataNodePlan.java} (63%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
