This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch downgrade-logger in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 137655c9ae2ae4c2fdcecf2d174f21a1e5abbd66 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Apr 10 20:36:35 2024 +0800 Pipe: downgrade logger from error to warn when failed to clear/close schema region listening queue --- .../java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java index 8c806fe2999..8ffa8f7e6d2 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java @@ -145,7 +145,7 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent { clearSchemaRegionListeningQueueIfNecessary(pipeMetaListFromCoordinator); closeSchemaRegionListeningQueueIfNecessary(validSchemaRegionIds, exceptionMessages); } catch (Exception e) { - throw new PipeException("Failed to clear/close schema region listening queue.", e); + LOGGER.warn("Failed to clear/close schema region listening queue.", e); } return exceptionMessages;
