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 2020/11/03 11:32:08 UTC
[iotdb] branch cluster_new updated (a75b365 -> 4715ad5)
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/iotdb.git.
from a75b365 Merge branch 'master' into cluster_new
new 3382d6b add raft log mechanism and use persist log to catch up
new b7cf81a add test
new 7caca25 add tests
new 851ef63 add use persist log to snapshot
new 40b08e1 remove useless lines
new 7949b1d fix fristLogIndex bug
new 6b83b80 add switch of whether use persist logs on disk to catchup
new 106afb2 fix log manager print messags
new b66f25d add getLogs UT
new 8779750 change forceRaftLogPeriodInMS to 1000
new 482e36b use persist log when getTerm not found in memory
new 29de7ef add recovery log data file
new bb5ba16 revert the test log level to warn
new 2463c42 fix get log term
new 30542c1 fix ut on windows
new 9eca1bc fix ut
new bc72be1 fix windows ut
new fa7f863 fix revoew
new e8a950a fix review and add per fetch limit when get logs from disks
new 6e38d4b fix ci
new b6e5983 fix review
new 70f8abc try to fix ci
new 777d8d7 try to fix windows ci
new 69561c2 fix exception not catch
new 6de89e2 fix null exception
new 6711945 resolve confilict
new d19f3b7 fix IT bug
new abf53f6 Merge branch 'apache_cluster_new' into apache_cluster_new_1023_raft_log_catch_up
new c745099 fix IT win bug
new 4715ad5 Merge pull request #1865 from neuyilan/apache_cluster_new_1023_raft_log_catch_up
The 5464 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 | 31 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 96 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 72 +-
.../iotdb/cluster/log/StableEntryManager.java | 11 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 39 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 3 +-
.../cluster/log/manage/CommittedEntryManager.java | 3 +
.../iotdb/cluster/log/manage/RaftLogManager.java | 19 +-
.../log/manage/serializable/LogManagerMeta.java | 31 +-
.../serializable/SyncLogDequeSerializer.java | 1110 +++++++++++++++-----
.../iotdb/cluster/server/member/RaftMember.java | 3 +
.../cluster/utils/nodetool/function/LogView.java | 21 +-
.../iotdb/cluster/log/CommitLogCallbackTest.java | 11 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 9 +
.../cluster/log/applier/DataLogApplierTest.java | 19 +-
.../cluster/log/applier/MetaLogApplierTest.java | 9 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 1 +
.../cluster/log/catchup/LogCatchUpTaskTest.java | 1 +
.../log/catchup/SnapshotCatchUpTaskTest.java | 1 +
.../manage/MetaSingleSnapshotLogManagerTest.java | 35 +-
.../cluster/log/manage/RaftLogManagerTest.java | 185 ++--
.../serializable/SyncLogDequeSerializerTest.java | 639 ++++++-----
.../cluster/log/snapshot/DataSnapshotTest.java | 14 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 3 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 17 +-
.../iotdb/cluster/partition/SlotManagerTest.java | 9 +-
.../caller/AppendGroupEntryHandlerTest.java | 8 +-
.../caller/AppendNodeEntryHandlerTest.java | 20 +-
.../handlers/caller/ElectionHandlerTest.java | 11 +-
.../handlers/caller/HeartbeatHandlerTest.java | 6 +-
.../handlers/caller/LogCatchUpHandlerTest.java | 6 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 6 +-
.../server/heartbeat/HeartbeatThreadTest.java | 7 +-
.../iotdb/cluster/server/member/MemberTest.java | 2 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 2 +-
35 files changed, 1712 insertions(+), 748 deletions(-)