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/27 11:58:03 UTC
[incubator-iotdb] branch cluster_new updated (4fa557c -> daac37b)
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 4fa557c multiple fix
add daac37b locally serial partition table when it changes
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/client/DataClient.java | 37 +++++++
.../apache/iotdb/cluster/client/MetaClient.java | 37 +++++++
.../cluster/exception/NotInSameGroupException.java | 4 +-
...ception.java => NotManagedSocketException.java} | 8 +-
...ava => PartitionTableUnavailableException.java} | 8 +-
.../iotdb/cluster/log/PartitionedSnapshot.java | 3 +-
.../apache/iotdb/cluster/log/SimpleSnapshot.java | 8 +-
.../iotdb/cluster/partition/PartitionTable.java | 2 -
.../cluster/partition/SocketPartitionTable.java | 44 ++++++++-
.../iotdb/cluster/server/DataClusterServer.java | 33 +++----
.../apache/iotdb/cluster/server/RaftServer.java | 4 +
.../handlers/caller/PullSnapshotHandler.java | 2 +-
.../cluster/server/heartbeat/HeartBeatThread.java | 11 +--
.../cluster/server/member/DataGroupMember.java | 30 +++---
.../cluster/server/member/MetaGroupMember.java | 108 +++++++++++++--------
.../iotdb/cluster/server/member/RaftMember.java | 24 +++--
pom.xml | 4 +-
service-rpc/src/main/thrift/cluster.thrift | 2 -
18 files changed, 250 insertions(+), 119 deletions(-)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/DataClient.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/MetaClient.java
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{IllegalSnapshotException.java => NotManagedSocketException.java} (76%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{NotInSameGroupException.java => PartitionTableUnavailableException.java} (76%)