You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/03/08 12:06:09 UTC
(iotdb) branch IT-test created (now d5e48a72165)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch IT-test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at d5e48a72165 Update SchemaExecutionVisitor.java
This branch includes the following new commits:
new d5e48a72165 Update SchemaExecutionVisitor.java
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Update SchemaExecutionVisitor.java
Posted by ro...@apache.org.
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 <ro...@apache.org>
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());
}
}