add exception handler

apache · Sep 27, 2024 · 068fa8b · 068fa8b
1 parent 6f48594
commit 068fa8b
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...e/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java b/...e/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
@@ -212,6 +212,11 @@ private void handleLoadFailure(final Pair<String, Boolean> filePair, final TSSta
           "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")) {
+      LOGGER.info(
+          "Error occurred when loading tsfile {} (isGeneratedByPipe = {}) due to the system is read only",
+          filePair.getLeft(),
+          filePair.getRight());
     } else {
       LOGGER.warn(
           "Failed to auto load tsfile {} (isGeneratedByPipe = {}), status: {}. File will be moved to fail directory.",
@@ -236,6 +241,11 @@ private void handleOtherException(final Pair<String, Boolean> filePair, final Ex
           "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")) {
+      LOGGER.info(
+          "Error occurred when loading tsfile {} (isGeneratedByPipe = {}) due to the system is read only",
+          filePair.getLeft(),
+          filePair.getRight());
     } else {
       LOGGER.warn(
           "Failed to auto load tsfile {} (isGeneratedByPipe = {}) because of an unexpected exception. File will be moved to fail directory.",