You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/11/22 10:33:21 UTC
[incubator-iotdb] branch cluster_new updated (0567d09 -> 59f8529)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 0567d09 refactor node addition in MetaGroupMember
add 59f8529 add catch up with snapshot
No new revisions were added by this update.
Summary of changes:
...xception.java => IllegalSnapshotException.java} | 8 +-
.../java/org/apache/iotdb/cluster/log/Log.java | 2 +
.../org/apache/iotdb/cluster/log/LogManager.java | 7 +
.../iotdb/cluster/log/PartitionedSnapshot.java | 78 ++++++
.../org/apache/iotdb/cluster/log/Snapshot.java | 7 +-
.../{server => log/catchup}/LogCatchUpTask.java | 70 ++----
.../cluster/log/catchup/SnapshotCatchUpTask.java | 87 +++++++
.../cluster/log/{ => manage}/MemoryLogManager.java | 37 +--
.../log/manage/PartitionedSnapshotLogManager.java | 46 ++++
.../log/manage/SingleSnapshotLogManager.java | 86 +++++++
.../apache/iotdb/cluster/log/meta/AddNodeLog.java | 5 +
.../iotdb/cluster/log/meta/PhysicalPlanLog.java | 6 +
.../cluster/partition/AddNodePartitionUpdate.java | 25 --
.../iotdb/cluster/partition/PartitionTable.java | 11 +-
.../cluster/partition/SocketPartitionTable.java | 45 ++--
.../iotdb/cluster/server/DataClusterServer.java | 54 ++++-
.../iotdb/cluster/server/MetaClusterServer.java | 16 +-
.../org/apache/iotdb/cluster/server/Response.java | 1 +
.../server/handlers/caller/ElectionHandler.java | 2 +-
.../server/handlers/caller/HeartBeatHandler.java | 13 +
.../server/handlers/caller/JoinClusterHandler.java | 3 -
...{CatchUpHandler.java => LogCatchUpHandler.java} | 33 ++-
.../handlers/caller/SnapshotCatchUpHandler.java | 48 ++++
.../server/heartbeat/DataHeartBeatThread.java | 36 +++
.../cluster/server/heartbeat/HeartBeatThread.java | 9 +-
.../server/heartbeat/MetaHeartBeatThread.java | 7 +
.../cluster/server/member/DataGroupMember.java | 100 ++++++--
.../cluster/server/member/MetaGroupMember.java | 59 +++--
.../iotdb/cluster/server/member/RaftMember.java | 264 +++++++++++----------
service-rpc/src/main/thrift/cluster.thrift | 35 ++-
30 files changed, 878 insertions(+), 322 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{RequestTimeOutException.java => IllegalSnapshotException.java} (78%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/PartitionedSnapshot.java
rename cluster/src/main/java/org/apache/iotdb/cluster/{server => log/catchup}/LogCatchUpTask.java (50%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/SnapshotCatchUpTask.java
rename cluster/src/main/java/org/apache/iotdb/cluster/log/{ => manage}/MemoryLogManager.java (63%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/PartitionedSnapshotLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/SingleSnapshotLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/AddNodePartitionUpdate.java
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{CatchUpHandler.java => LogCatchUpHandler.java} (81%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/SnapshotCatchUpHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartBeatThread.java