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 0a146e7 fix tests
new 044e5a3 record the down node
new 7b0ea89 fix election vote and MetaSimpleSnspshot
new 1c7c5fe inscrease the catch up timeout
new 3460bf1 code refine
new abf8f4e Merge pull request #1777 from
neuyilan/apache_cluster_new_0927_fix_down_startup
The 5133 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../resources/conf/iotdb-cluster.properties | 6 ++
.../cluster/client/async/AsyncClientPool.java | 60 +++++++++++++--
.../cluster/client/async/AsyncDataClient.java | 15 +++-
.../cluster/client/async/AsyncMetaClient.java | 8 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 18 ++++-
.../iotdb/cluster/config/ClusterDescriptor.java | 12 ++-
.../apache/iotdb/cluster/log/LogDispatcher.java | 31 +++++---
.../iotdb/cluster/log/catchup/CatchUpTask.java | 6 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 3 +
.../cluster/log/catchup/SnapshotCatchUpTask.java | 5 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 5 --
.../iotdb/cluster/log/manage/RaftLogManager.java | 6 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 16 +++-
.../cluster/query/manage/QueryCoordinator.java | 9 ++-
.../cluster/server/heartbeat/HeartbeatThread.java | 9 ++-
.../iotdb/cluster/server/member/RaftMember.java | 23 +++---
.../apache/iotdb/cluster/utils/ClusterNode.java | 11 +++
.../cluster/log/snapshot/FileSnapshotTest.java | 19 +++++
.../log/snapshot/MetaSimpleSnapshotTest.java | 90 ++++++++++++++++++++++
19 files changed, 293 insertions(+), 59 deletions(-)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshotTest.java
