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/10/18 03:06:19 UTC

(iotdb) branch master updated: Active Load: Fix load tsfile failed when system is read only and not have the error message. (#13805)

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 5f1287cf3c5 Active Load: Fix load tsfile failed when system is read only and not have the error message. (#13805)
5f1287cf3c5 is described below

commit 5f1287cf3c5bf46c12b65a7a2f2b4c3cbfcddd64
Author: YC27 <76...@users.noreply.github.com>
AuthorDate: Fri Oct 18 11:06:13 2024 +0800

    Active Load: Fix load tsfile failed when system is read only and not have the error message. (#13805)
---
 .../iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
index 2f30da15e55..ddca16d9132 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
@@ -216,7 +216,8 @@ public class ActiveLoadTsFileLoader {
           "Rejecting auto load tsfile {} (isGeneratedByPipe = {}) due to memory constraints, will retry later.",
           filePair.getLeft(),
           filePair.getRight());
-    } else if (status.getMessage() != null && status.getMessage().contains("read only")) {
+    } else if (CommonDescriptor.getInstance().getConfig().isReadOnly()
+        || (status.getMessage() != null && status.getMessage().contains("read only"))) {
       LOGGER.info(
           "Rejecting auto load tsfile {} (isGeneratedByPipe = {}) due to the system is read only, will retry later.",
           filePair.getLeft(),
@@ -245,7 +246,8 @@ public class ActiveLoadTsFileLoader {
           "Rejecting auto load tsfile {} (isGeneratedByPipe = {}) due to memory constraints, will retry later.",
           filePair.getLeft(),
           filePair.getRight());
-    } else if (e.getMessage() != null && e.getMessage().contains("read only")) {
+    } else if (CommonDescriptor.getInstance().getConfig().isReadOnly()
+        || (e.getMessage() != null && e.getMessage().contains("read only"))) {
       LOGGER.info(
           "Rejecting auto load tsfile {} (isGeneratedByPipe = {}) due to the system is read only, will retry later.",
           filePair.getLeft(),