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 2f30da15e55d4..ddca16d91321f 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 @@ private void handleLoadFailure(final Pair 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")) { + } 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 @@ private void handleOtherException(final Pair 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")) { + } 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(),