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 c9cd472 fix uncaught exception in tests
add 9295e9a fix sonar issues fix execute non-query locally
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 59 ++++++----
.../java/org/apache/iotdb/cluster/ClusterMain.java | 10 +-
.../apache/iotdb/cluster/RemoteTsFileResource.java | 3 -
.../iotdb/cluster/client/async/DataClient.java | 2 +-
.../iotdb/cluster/client/async/MetaClient.java | 2 +-
.../cluster/client/sync/SyncClientAdaptor.java | 32 +++---
.../iotdb/cluster/log/applier/BaseApplier.java | 5 -
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 4 +-
.../cluster/log/catchup/SnapshotCatchUpTask.java | 2 +-
.../cluster/log/snapshot/PullSnapshotTask.java | 2 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 4 +-
.../query/groupby/RemoteGroupByExecutor.java | 4 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 4 +-
.../query/reader/RemoteSimpleSeriesReader.java | 4 +-
.../apache/iotdb/cluster/server/ClientServer.java | 2 +-
.../iotdb/cluster/server/DataClusterServer.java | 2 +-
.../iotdb/cluster/server/MetaClusterServer.java | 2 +-
.../apache/iotdb/cluster/server/RaftServer.java | 11 +-
.../org/apache/iotdb/cluster/server/Response.java | 2 -
.../cluster/server/heartbeat/HeartbeatThread.java | 12 +--
.../cluster/server/member/DataGroupMember.java | 2 +-
.../cluster/server/member/MetaGroupMember.java | 43 ++++++--
.../iotdb/cluster/server/member/RaftMember.java | 12 +--
.../apache/iotdb/cluster/utils/PartitionUtils.java | 119 ++++++++++-----------
.../log/catchup/SnapshotCatchUpTaskTest.java | 4 +-
.../cluster/partition/SlotPartitionTableTest.java | 18 ++--
.../server/heartbeat/HeartbeatThreadTest.java | 7 +-
.../cluster/server/member/DataGroupMemberTest.java | 12 +--
.../cluster/server/member/MetaGroupMemberTest.java | 18 ++--
.../org/apache/iotdb/db/service/TSServiceImpl.java | 20 ++--
30 files changed, 227 insertions(+), 196 deletions(-)
