This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster_scalability
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f3df198 This commit fix following issues: 1. fix a bug of remove the
leader of a data group, the election can not be triggered immediately. 2. fix a
bug of read same ByteBuffer when parallel send log to all data groups, which is
fixed by adding clone ByteBuffer when split plan. 3. When remove a node, the
data group whose header is this node can not reset leader to null which will
cause slow of data migration 4. The election of data group does not need to
make sure that meta log [...]
new 140cbb5 This commit fix following issues: 1. fix some bug of read
process 2. remove useless logic to make sure that meta log is also newest in
election of data group 3. add last applied partition table version in data
group member which will remove all syncLeader() when adding/removing node
new 82abad0 This commit fix following issues: 1. add lock to put
DataGroupMember to headerMap in order to handle concurrent issue 2. fix a bug
of using not started DataGroupMember to pull snapshot 3. put exile to backgroud
new eb45f30 This commit fix following issues: 1. fix a dead-lock of
headerGroupMap and asyncServiceMap in method addDataGroup. 2. add synchronized
monitor in heartbeat wait object.
new 3a91a25 remove useless parameter
The 4 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:
.../java/org/apache/iotdb/cluster/ClusterMain.java | 4 +-
.../iotdb/cluster/config/ClusterConstant.java | 2 +
.../iotdb/cluster/coordinator/Coordinator.java | 2 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 2 +
.../cluster/log/snapshot/PullSnapshotTask.java | 2 +
.../iotdb/cluster/query/reader/DataSourceInfo.java | 6 +-
.../iotdb/cluster/server/DataClusterServer.java | 52 ++++----
.../org/apache/iotdb/cluster/server/Response.java | 2 +
.../server/handlers/caller/ElectionHandler.java | 4 +
.../cluster/server/member/DataGroupMember.java | 145 +++++++++++++--------
.../cluster/server/member/MetaGroupMember.java | 61 +++++++--
.../iotdb/cluster/server/member/RaftMember.java | 36 +++--
.../cluster/server/member/MetaGroupMemberTest.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 1 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 1 +
thrift/src/main/thrift/cluster.thrift | 2 +-
16 files changed, 207 insertions(+), 118 deletions(-)
