[iotdb] branch rel/0.13 updated: [To rel/0.13][IOTDB-3904]fix set/unset, drop, and deactivate template api in sessionPool #6775

[zy...@apache.org]

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

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


The following commit(s) were added to refs/heads/rel/0.13 by this push:
     new ae3a580798 [To rel/0.13][IOTDB-3904]fix set/unset, drop, and deactivate template api in sessionPool #6775
ae3a580798 is described below

commit ae3a5807983641a6e7ca7034f1464d3fc624ba13
Author: ZhaoXin <x_...@163.com>
AuthorDate: Wed Jul 27 09:29:50 2022 +0800

    [To rel/0.13][IOTDB-3904]fix set/unset, drop, and deactivate template api in sessionPool #6775
    
    [To rel/0.13][IOTDB-3904]fix set/unset, drop, and deactivate template api in sessionPool #6775
---
 session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
index 57b3d1dbb4..82fc8107aa 100644
--- a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
+++ b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
@@ -2097,6 +2097,7 @@ public class SessionPool {
       try {
         session.setSchemaTemplate(templateName, prefixPath);
         putBack(session);
+        return;
       } catch (IoTDBConnectionException e) {
         // TException means the connection is broken, remove it and get a new one.
         logger.warn(
@@ -2116,6 +2117,7 @@ public class SessionPool {
       try {
         session.unsetSchemaTemplate(prefixPath, templateName);
         putBack(session);
+        return;
       } catch (IoTDBConnectionException e) {
         // TException means the connection is broken, remove it and get a new one.
         logger.warn(
@@ -2135,6 +2137,7 @@ public class SessionPool {
       try {
         session.createTimeseriesOfTemplateOnPath(path);
         putBack(session);
+        return;
       } catch (IoTDBConnectionException e) {
         // TException means the connection is broken, remove it and get a new one.
         logger.warn(String.format("create timeseries of template on [%s] failed", path), e);
@@ -2153,6 +2156,7 @@ public class SessionPool {
       try {
         session.deactivateTemplateOn(templateName, prefixPath);
         putBack(session);
+        return;
       } catch (IoTDBConnectionException e) {
         // TException means the connection is broken, remove it and get a new one.
         logger.warn(
@@ -2172,6 +2176,7 @@ public class SessionPool {
       try {
         session.dropSchemaTemplate(templateName);
         putBack(session);
+        return;
       } catch (IoTDBConnectionException e) {
         // TException means the connection is broken, remove it and get a new one.
         logger.warn(String.format("dropSchemaTemplate [%s] failed", templateName), e);