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:10 UTC
(iotdb) 01/01: Update SchemaExecutionVisitor.java
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());
}
}