This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IT-test in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d5e48a72165c166f9b93da7cfd07146546b6d59c Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Mar 8 20:06:02 2024 +0800 Update SchemaExecutionVisitor.java --- .../statemachine/schemaregion/SchemaExecutionVisitor.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitor.java index 172b42ae38c..26a4f5a4e77 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitor.java @@ -543,17 +543,12 @@ public class SchemaExecutionVisitor extends PlanVisitor<TSStatus, ISchemaRegion> final SchemaRegionId id = schemaRegion.getSchemaRegionId(); final SchemaRegionListeningQueue queue = PipeAgent.runtime().schemaListener(id); try { - if (node.isOpen() && !queue.isOpened()) { - logger.info("Opened pipe listening queue on schema region {}", id); + if (!queue.isOpened()) { queue.open(); - } else if (!node.isOpen() && queue.isOpened()) { - logger.info("Closed pipe listening queue on schema region {}", id); - queue.close(); } return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()); - } catch (IOException e) { - return new TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode()) - .setMessage("Failed to clear the queue, because " + e.getMessage()); + } catch (IllegalStateException e) { + return new TSStatus(TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()); } }
