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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4fa7bf44b3 [IOTDB-4123]Authority query will be stuck when confignode 
is down (#6984)
4fa7bf44b3 is described below

commit 4fa7bf44b341200c2e65995fd427b69356c8ad82
Author: Yifu Zhou <[email protected]>
AuthorDate: Sat Aug 13 17:29:36 2022 +0800

    [IOTDB-4123]Authority query will be stuck when confignode is down (#6984)
    
    [IOTDB-4123]Authority query will be stuck when confignode is down (#6984)
---
 .../src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java 
b/server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
index 9a1bc33de0..1267ae4d7e 100644
--- a/server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
@@ -170,6 +170,7 @@ public class ClusterAuthorityFetcher implements 
IAuthorityFetcher {
       authorizerResp.setStatus(
           RpcUtils.getStatus(
               TSStatusCode.EXECUTE_STATEMENT_ERROR, "Failed to connect to 
config node."));
+      future.setException(new 
StatementExecutionException(authorizerResp.getStatus()));
     } catch (AuthException e) {
       future.setException(e);
     }

Reply via email to