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 ee05680 fix exception
add fd16dba [IOTDB-567] Apache IoTDB's Peer Tracker for The Raft Protocol
(#1157)
No new revisions were added by this update.
Summary of changes:
.../iotdb/cluster/log/catchup/CatchUpTask.java | 168 +++++++++++++++++++++
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 40 ++---
.../java/org/apache/iotdb/cluster/server/Peer.java | 44 ++++--
.../handlers/caller/AppendNodeEntryHandler.java | 20 ++-
.../server/handlers/caller/HeartbeatHandler.java | 7 +-
.../cluster/server/member/DataGroupMember.java | 10 +-
.../cluster/server/member/MetaGroupMember.java | 4 +
.../iotdb/cluster/server/member/RaftMember.java | 120 ++++++---------
...ogCatchUpTaskTest.java => CatchUpTaskTest.java} | 119 ++++++++-------
.../caller/AppendNodeEntryHandlerTest.java | 13 ++
.../handlers/caller/HeartbeatHandlerTest.java | 7 +-
11 files changed, 379 insertions(+), 173 deletions(-)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/CatchUpTask.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/GroupByFillPlan.java
=> cluster/src/main/java/org/apache/iotdb/cluster/server/Peer.java (52%)
copy
cluster/src/test/java/org/apache/iotdb/cluster/log/catchup/{LogCatchUpTaskTest.java
=> CatchUpTaskTest.java} (55%)
