[iotdb] branch kyy updated: throw exception

[yuyuankang]

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

yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/kyy by this push:
     new a618ad8  throw exception
a618ad8 is described below

commit a618ad86dbb83fea8e94b9930b5b3a1b2b73c240
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Mon Oct 12 20:08:05 2020 +0800

    throw exception
---
 .../main/java/org/apache/iotdb/cluster/metadata/CMManager.java    | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java
index 3614fa7..c2b3e48 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java
@@ -1188,7 +1188,8 @@ public class CMManager extends MManager {
   }
 
   private void showTimeseries(PartitionGroup group, ShowTimeSeriesPlan plan,
-      Set<ShowTimeSeriesResult> resultSet, QueryContext context) throws 
CheckConsistencyException {
+      Set<ShowTimeSeriesResult> resultSet, QueryContext context)
+      throws CheckConsistencyException, MetadataException {
     if (group.contains(metaGroupMember.getThisNode())) {
       showLocalTimeseries(group, plan, resultSet, context);
     } else {
@@ -1197,7 +1198,8 @@ public class CMManager extends MManager {
   }
 
   private void showLocalTimeseries(PartitionGroup group, ShowTimeSeriesPlan 
plan,
-      Set<ShowTimeSeriesResult> resultSet, QueryContext context) throws 
CheckConsistencyException {
+      Set<ShowTimeSeriesResult> resultSet, QueryContext context)
+      throws CheckConsistencyException, MetadataException {
     Node header = group.getHeader();
     DataGroupMember localDataMember = 
metaGroupMember.getLocalDataMember(header);
     localDataMember.syncLeaderWithConsistencyCheck();
@@ -1208,6 +1210,7 @@ public class CMManager extends MManager {
     } catch (MetadataException e) {
       logger
           .error("Cannot execute show timeseries plan  {} from {} locally.", 
plan, group);
+      throw e;
     }
   }
 
@@ -1217,7 +1220,6 @@ public class CMManager extends MManager {
     for (Node node : group) {
       try {
         resultBinary = showRemoteTimeseries(node, group, plan);
-
         if (resultBinary != null) {
           break;
         }