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/26 13:15:09 UTC
[incubator-iotdb] branch cluster_new updated (6b1cb5f -> 4fa557c)

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 6b1cb5f  add logs and some refinements
     add 4fa557c  multiple fix

No new revisions were added by this update.

Summary of changes:
 .../resources/conf/iotdb-cluster.properties        |  7 +-
 .../java/org/apache/iotdb/cluster/ClusterMain.java |  1 +
 .../apache/iotdb/cluster/config/ClusterConfig.java | 10 ++-
 .../iotdb/cluster/config/ClusterDescriptor.java    |  3 +
 .../cluster/exception/NotInSameGroupException.java |  5 +-
 .../iotdb/cluster/log/applier/MetaLogApplier.java  |  1 +
 .../apache/iotdb/cluster/log/meta/AddNodeLog.java  | 15 +++-
 .../cluster/partition/SocketPartitionTable.java    |  5 +-
 .../iotdb/cluster/server/DataClusterServer.java    | 65 ++++++++++++----
 .../iotdb/cluster/server/MetaClusterServer.java    |  4 +-
 .../handlers/caller/AppendGroupEntryHandler.java   | 14 +---
 .../handlers/caller/AppendNodeEntryHandler.java    | 58 +++++++-------
 .../server/handlers/caller/ElectionHandler.java    | 33 ++++----
 .../server/handlers/caller/HeartBeatHandler.java   | 38 ++++-----
 .../server/handlers/caller/JoinClusterHandler.java | 19 ++---
 .../server/handlers/caller/LogCatchUpHandler.java  | 71 +++++++++--------
 .../handlers/caller/PullSnapshotHandler.java       | 20 ++---
 .../handlers/caller/SnapshotCatchUpHandler.java    | 17 ++---
 .../handlers/forwarder/ForwardAddNodeHandler.java  | 11 +--
 .../forwarder/ForwardPullSnapshotHandler.java      | 13 +---
 .../server/heartbeat/DataHeartBeatThread.java      |  2 +
 .../cluster/server/heartbeat/HeartBeatThread.java  | 43 ++++++-----
 .../cluster/server/member/DataGroupMember.java     | 89 +++++++++++++++-------
 .../cluster/server/member/MetaGroupMember.java     | 73 +++++++++++-------
 .../iotdb/cluster/server/member/RaftMember.java    | 80 +++++++++++--------
 .../apache/iotdb/cluster/utils/SerializeUtils.java |  8 +-
 pom.xml                                            |  6 +-
 .../resources/conf/iotdb-engine.properties         |  1 +
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +++
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |  2 +
 .../java/org/apache/iotdb/db/service/IoTDB.java    |  4 +-
 service-rpc/src/main/thrift/cluster.thrift         |  2 +-
 32 files changed, 416 insertions(+), 314 deletions(-)