[iotdb] branch master updated: fix client bug during deactivate template (#7833)

[haonan]

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

haonan 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 0460a054a1 fix client bug during deactivate template (#7833)
0460a054a1 is described below

commit 0460a054a1f55a92f84f34e644161979dd99dd8e
Author: Marcos_Zyk <38524330+marcos...@users.noreply.github.com>
AuthorDate: Mon Oct 31 20:41:21 2022 +0800

    fix client bug during deactivate template (#7833)
---
 .../apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java
index 4861f86bcd..e6f1c6375c 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java
@@ -296,16 +296,19 @@ public class AsyncDataNodeClientPool {
               (TDeactivateTemplateReq) clientHandler.getRequest(requestId),
               (DeleteSchemaRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, 
targetDataNode));
+          break;
         case UPDATE_TEMPLATE:
           client.updateTemplate(
               (TUpdateTemplateReq) clientHandler.getRequest(requestId),
               (AsyncTSStatusRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, 
targetDataNode));
+          break;
         case COUNT_PATHS_USING_TEMPLATE:
           client.countPathsUsingTemplate(
               (TCountPathsUsingTemplateReq) 
clientHandler.getRequest(requestId),
               (CountPathsUsingTemplateRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, 
targetDataNode));
+          break;
         default:
           LOGGER.error(
               "Unexpected DataNode Request Type: {} when 
sendAsyncRequestToDataNode",