[incubator-iotdb] branch cluster updated: fix an error

[lta]

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

lta pushed a commit to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/cluster by this push:
     new 70c03c4  fix an error
70c03c4 is described below

commit 70c03c4c17af61b3811aff40b5e89064f0424249
Author: lta <litiana...@163.com>
AuthorDate: Thu Mar 28 22:37:46 2019 +0800

    fix an error
---
 .../apache/iotdb/cluster/rpc/processor/QueryMetadataAsyncProcessor.java | 1 -
 .../main/java/org/apache/iotdb/cluster/rpc/response/BasicResponse.java  | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/QueryMetadataAsyncProcessor.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/QueryMetadataAsyncProcessor.java
index cb9132d..dd292ad 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/QueryMetadataAsyncProcessor.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/QueryMetadataAsyncProcessor.java
@@ -61,7 +61,6 @@ public class QueryMetadataAsyncProcessor extends 
BasicAsyncUserProcessor<QueryMe
           final Task task = new Task();
           Set<String> storageGroupSet = 
metadataHolder.getFsm().getAllStorageGroups();
           task.setDone(status -> {
-            asyncContext.sendResponse();
             if (!status.isOk()) {
               asyncContext.sendResponse(
                   new QueryMetadataResponse(false, false, null, 
status.getErrorMsg()));
diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/response/BasicResponse.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/response/BasicResponse.java
index c257fdc..61812ae 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/response/BasicResponse.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/response/BasicResponse.java
@@ -24,7 +24,7 @@ public abstract class BasicResponse implements Serializable {
 
   private static final long serialVersionUID = 7509860476962493127L;
   /**
-   * Mark if it's need to redirect to right leader
+   * Mark if it needs to redirect to right leader
    */
   private boolean redirected;
   /**