This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


    from ceecd32  mvn spotless:apply
     add 99c1da3  [cluster refactor] let borrowClient throw IOException instead 
of Exception (#4252)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iotdb/cluster/ClusterIoTDB.java     |  5 +-
 .../apache/iotdb/cluster/client/ClientManager.java | 58 ++++++++++++-----
 .../iotdb/cluster/client/IClientManager.java       |  6 +-
 .../cluster/client/async/AsyncDataClient.java      |  7 +-
 .../cluster/client/async/AsyncMetaClient.java      |  4 +-
 .../iotdb/cluster/coordinator/Coordinator.java     |  7 +-
 .../iotdb/cluster/log/snapshot/FileSnapshot.java   |  2 +-
 .../apache/iotdb/cluster/metadata/CMManager.java   | 29 ++++-----
 .../apache/iotdb/cluster/metadata/MetaPuller.java  | 27 ++++----
 .../iotdb/cluster/query/ClusterPlanExecutor.java   | 51 ++++++++-------
 .../cluster/query/aggregate/ClusterAggregator.java | 13 ++--
 .../cluster/query/fill/ClusterPreviousFill.java    |  7 +-
 .../query/groupby/RemoteGroupByExecutor.java       | 14 ++--
 .../query/last/ClusterLastQueryExecutor.java       | 39 ++++++-----
 .../cluster/query/reader/ClusterReaderFactory.java | 12 ++--
 .../iotdb/cluster/query/reader/DataSourceInfo.java | 13 ++--
 .../reader/RemoteSeriesReaderByTimestamp.java      |  4 --
 .../query/reader/RemoteSimpleSeriesReader.java     |  4 --
 .../query/reader/mult/MultDataSourceInfo.java      |  4 +-
 .../query/reader/mult/RemoteMultSeriesReader.java  |  4 --
 .../iotdb/cluster/server/ClusterTSServiceImpl.java |  7 +-
 .../cluster/server/PullSnapshotHintService.java    |  2 +-
 .../iotdb/cluster/server/member/RaftMember.java    |  4 +-
 .../reader/mult/RemoteMultSeriesReaderTest.java    | 76 ++++++++++++----------
 .../iotdb/cluster/server/member/BaseMember.java    |  2 +-
 .../cluster/server/member/MetaGroupMemberTest.java |  4 +-
 26 files changed, 209 insertions(+), 196 deletions(-)

Reply via email to