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/04/23 02:00:18 UTC
[incubator-iotdb] branch cluster_new updated (1fb8d0f -> 792cb6a)
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 1fb8d0f fix align by device fix insertion failure caused by metadata fetch exception
add 792cb6a Refactoring raft log module (#975)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 8 -
...Exception.java => EntryCompactedException.java} | 10 +-
...ception.java => EntryUnavailableException.java} | 9 +-
...ava => GetEntriesWrongParametersException.java} | 9 +-
...n.java => TruncateCommittedEntryException.java} | 10 +-
.../org/apache/iotdb/cluster/log/HardState.java | 95 +++
.../java/org/apache/iotdb/cluster/log/Log.java | 5 +-
.../org/apache/iotdb/cluster/log/LogParser.java | 6 +
.../org/apache/iotdb/cluster/log/Snapshot.java | 10 +-
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 5 +-
.../cluster/log/logtypes/EmptyContentLog.java | 69 ++
.../cluster/log/logtypes/PhysicalPlanLog.java | 6 -
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 1 +
.../cluster/log/manage/CommittedEntryManager.java | 222 ++++++
.../manage/FilePartitionedSnapshotLogManager.java | 19 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 22 +-
.../log/manage/PartitionedSnapshotLogManager.java | 9 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 435 +++++++++++
.../StableEntryManager.java} | 26 +-
.../log/manage/UnCommittedEntryManager.java | 232 ++++++
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 2 +-
.../cluster/log/snapshot/PartitionedSnapshot.java | 8 +-
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 15 +-
.../cluster/server/member/DataGroupMember.java | 15 +-
.../cluster/server/member/MetaGroupMember.java | 51 +-
.../iotdb/cluster/server/member/RaftMember.java | 34 +-
.../iotdb/cluster/common/TestLogManager.java | 90 +--
.../log/manage/CommittedEntryManagerTest.java | 471 ++++++++++++
.../cluster/log/manage/DiskLogManagerTest.java | 1 +
.../FilePartitionedSnapshotLogManagerTest.java | 11 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 12 +-
.../cluster/log/manage/RaftLogManagerTest.java | 840 +++++++++++++++++++++
.../log/manage/UnCommittedEntryManagerTest.java | 444 +++++++++++
.../serializable/SyncLogDequeSerializerTest.java | 1 -
.../handlers/caller/ElectionHandlerTest.java | 1 -
.../handlers/caller/HeartbeatHandlerTest.java | 6 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 22 +-
.../server/heartbeat/HeartbeatThreadTest.java | 20 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 13 +-
.../cluster/server/member/DataGroupMemberTest.java | 55 +-
.../iotdb/cluster/server/member/MemberTest.java | 7 +-
.../cluster/server/member/MetaGroupMemberTest.java | 17 +-
42 files changed, 3044 insertions(+), 300 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{QueryTimeOutException.java => EntryCompactedException.java} (75%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{QueryTimeOutException.java => EntryUnavailableException.java} (77%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{UnknownLogTypeException.java => GetEntriesWrongParametersException.java} (80%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{UnsupportedPlanException.java => TruncateCommittedEntryException.java} (75%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/HardState.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/logtypes/EmptyContentLog.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/RaftLogManager.java
copy cluster/src/main/java/org/apache/iotdb/cluster/log/{snapshot/SnapshotFactory.java => manage/StableEntryManager.java} (59%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManager.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/CommittedEntryManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/UnCommittedEntryManagerTest.java