(iotdb) branch master updated: Pipe: Improved the failure log of closing schema region queue when the region is being stopped (#12828)

[rong]

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

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 6383752c2fa Pipe: Improved the failure log of closing schema region 
queue when the region is being stopped (#12828)
6383752c2fa is described below

commit 6383752c2facb389e99ed547dd1d824b181aacc3
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Jul 1 17:58:54 2024 +0800

    Pipe: Improved the failure log of closing schema region queue when the 
region is being stopped (#12828)
---
 .../iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java      | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

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 c91c76d36be..8fce2188dc7 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
@@ -159,7 +159,11 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent {
           
clearSchemaRegionListeningQueueIfNecessary(pipeMetaListFromCoordinator);
       closeSchemaRegionListeningQueueIfNecessary(validSchemaRegionIds, 
exceptionMessages);
     } catch (final Exception e) {
-      throw new PipeException("Failed to clear/close schema region listening 
queue.", e);
+      LOGGER.warn(
+          "Failed to clear/close the schema region listening queue, because 
{}. Will wait until success or the region's state machine is stopped.",
+          e.getMessage());
+      exceptionMessages.add(
+          new TPushPipeMetaRespExceptionMessage(null, e.getMessage(), 
System.currentTimeMillis()));
     }
 
     return exceptionMessages;
@@ -231,7 +235,11 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent {
                           new PipeOperateSchemaQueueNode(new PlanNodeId(""), 
false));
                 } catch (final ConsensusException e) {
                   throw new PipeException(
-                      "Failed to close listening queue for SchemaRegion " + 
schemaRegionId, e);
+                      "Failed to close listening queue for SchemaRegion "
+                          + schemaRegionId
+                          + ", because "
+                          + e.getMessage(),
+                      e);
                 }
               }
             });