You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/10/31 12:41:27 UTC

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

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 <38...@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",