You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2021/05/27 16:44:25 UTC

[iotdb] branch cluster_scalability updated (57e0875 -> 584bfa6)

This is an automated email from the ASF dual-hosted git repository.

lta pushed a change to branch cluster_scalability
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


    from 57e0875  fix some issues according to pr comments
     add 584bfa6  fix some issues according to pr comments

No new revisions were added by this update.

Summary of changes:
 .../iotdb/cluster/log/snapshot/FileSnapshot.java   | 55 ++++++++++------------
 .../cluster/log/snapshot/MetaSimpleSnapshot.java   |  4 +-
 .../cluster/log/snapshot/PartitionedSnapshot.java  |  6 +--
 .../cluster/log/snapshot/PullSnapshotTask.java     |  2 +-
 .../cluster/log/snapshot/SnapshotInstaller.java    |  6 +--
 .../iotdb/cluster/partition/PartitionGroup.java    |  4 ++
 .../iotdb/cluster/partition/PartitionTable.java    |  3 ++
 .../cluster/partition/slot/SlotPartitionTable.java | 14 ++++++
 .../iotdb/cluster/server/StoppedMemberManager.java | 15 +++---
 .../server/handlers/caller/NodeStatusHandler.java  |  3 +-
 .../server/heartbeat/MetaHeartbeatThread.java      | 17 ++++---
 .../cluster/server/member/DataGroupMember.java     |  2 +-
 .../cluster/server/member/MetaGroupMember.java     | 18 +++----
 .../cluster/utils/nodetool/ClusterMonitor.java     |  6 ++-
 .../cluster/utils/nodetool/function/Status.java    | 11 +++--
 .../apache/iotdb/cluster/common/TestSnapshot.java  |  4 +-
 .../cluster/log/snapshot/FileSnapshotTest.java     | 12 ++---
 .../log/snapshot/MetaSimpleSnapshotTest.java       |  2 +-
 .../log/snapshot/PartitionedSnapshotTest.java      |  2 +-
 .../iotdb/cluster/log/snapshot/SimpleSnapshot.java |  4 +-
 .../server/heartbeat/MetaHeartbeatThreadTest.java  |  3 ++
 .../cluster/server/member/DataGroupMemberTest.java |  2 +-
 .../engine/storagegroup/StorageGroupProcessor.java | 10 ++++
 23 files changed, 123 insertions(+), 82 deletions(-)