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 214c49a2108 new iot_consensus_throttle_threshold_in_byte (#12333)
add f4804a41440 Thread-safety load balance infrastructure (#12330)
No new revisions were added by this update.
Summary of changes:
.../client/async/AsyncDataNodeClientPool.java | 3 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 22 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 73 ++--
...CHandler.java => TransferLeaderRPCHandler.java} | 20 +-
.../client/sync/SyncDataNodeClientPool.java | 9 +-
.../iotdb/confignode/manager/ConfigManager.java | 33 +-
.../iotdb/confignode/manager/load/LoadManager.java | 139 +++----
.../manager/load/balancer/RouteBalancer.java | 416 +++++++++++++--------
.../router/priority/GreedyPriorityBalancer.java | 4 +-
.../router/priority/LeaderPriorityBalancer.java | 4 +-
.../load/cache/AbstractHeartbeatSample.java} | 33 +-
.../manager/load/cache/AbstractLoadCache.java | 86 +++++
.../manager/load/cache/AbstractStatistics.java | 49 +++
.../confignode/manager/load/cache/LoadCache.java | 284 ++++++--------
.../load/cache/consensus/ConsensusGroupCache.java | 61 +++
.../consensus/ConsensusGroupHeartbeatSample.java | 27 +-
.../cache/consensus/ConsensusGroupStatistics.java} | 34 +-
.../manager/load/cache/node/BaseNodeCache.java | 106 +-----
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 37 +-
.../load/cache/node/NodeHeartbeatSample.java | 70 ++--
.../manager/load/cache/node/NodeStatistics.java | 94 +----
.../manager/load/cache/region/RegionCache.java | 56 +--
.../load/cache/region/RegionGroupCache.java | 96 ++---
.../load/cache/region/RegionGroupStatistics.java | 80 ++--
.../load/cache/region/RegionHeartbeatSample.java | 27 +-
.../load/cache/region/RegionStatistics.java | 38 +-
.../manager/load/cache/route/RegionRouteCache.java | 147 --------
.../manager/load/service/EventService.java | 272 ++++++++++++++
.../manager/load/service/HeartbeatService.java | 26 +-
.../manager/load/service/StatisticsService.java | 237 +-----------
...va => ConsensusGroupStatisticsChangeEvent.java} | 30 +-
.../load/subscriber/IClusterStatusSubscriber.java | 8 +-
...scriber.java => NodeStatisticsChangeEvent.java} | 25 +-
....java => RegionGroupStatisticsChangeEvent.java} | 24 +-
.../iotdb/confignode/manager/node/NodeManager.java | 13 +-
.../runtime/PipeLeaderChangeHandler.java | 41 +-
.../runtime/PipeRuntimeCoordinator.java | 23 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 45 +--
.../procedure/env/RegionMaintainHandler.java | 43 ++-
.../impl/node/AddConfigNodeProcedure.java | 10 +-
.../impl/region/CreateRegionGroupsProcedure.java | 78 ++--
.../impl/schema/DeleteDatabaseProcedure.java | 5 +-
.../router/priority/GreedyPriorityTest.java | 10 +-
.../priority/LeaderPriorityBalancerTest.java | 8 +-
...CacheTest.java => ConsensusGroupCacheTest.java} | 20 +-
.../manager/load/cache/NodeCacheTest.java | 37 +-
.../manager/load/cache/RegionGroupCacheTest.java | 116 +++---
.../persistence/node/NodeStatisticsTest.java | 66 ----
.../statistics/RegionGroupStatisticsTest.java | 76 ----
.../partition/statistics/RegionStatisticsTest.java | 66 ----
.../org/apache/iotdb/consensus/IConsensus.java | 8 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 7 +
.../iotdb/consensus/ratis/RatisConsensus.java | 12 +
.../iotdb/consensus/simple/SimpleConsensus.java | 5 +
.../impl/DataNodeInternalRPCServiceImpl.java | 52 ++-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../src/main/thrift/datanode.thrift | 8 +-
58 files changed, 1594 insertions(+), 1865 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{AsyncTSStatusRPCHandler.java
=> TransferLeaderRPCHandler.java} (80%)
rename
iotdb-core/confignode/src/{test/java/org/apache/iotdb/confignode/manager/load/cache/RegionRouteCacheTest.java
=>
main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractHeartbeatSample.java}
(51%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractStatistics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupCache.java
copy
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupHeartbeatSample.java
(60%)
mode change 100755 => 100644
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/common/NodeRef.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupStatistics.java}
(54%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/route/RegionRouteCache.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{RouteChangeEvent.java
=> ConsensusGroupStatisticsChangeEvent.java} (52%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{IClusterStatusSubscriber.java
=> NodeStatisticsChangeEvent.java} (54%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{StatisticsChangeEvent.java
=> RegionGroupStatisticsChangeEvent.java} (65%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/{LoadCacheTest.java
=> ConsensusGroupCacheTest.java} (58%)
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/node/NodeStatisticsTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatisticsTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionStatisticsTest.java
