Pipe: Avoid type conversion if error on receiver is caused by insuffi…

…cient memory (#13569)
apache · Sep 22, 2024 · f87de7f · f87de7f
1 parent 97e5c35
commit f87de7f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...g/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java b/...g/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
@@ -83,7 +83,9 @@ public Optional<TSStatus> visitNode(final StatementNode statementNode, final TSS
   @Override
   public Optional<TSStatus> visitLoadFile(
       final LoadTsFileStatement loadTsFileStatement, final TSStatus status) {
-    if (status.getCode() != TSStatusCode.LOAD_FILE_ERROR.getStatusCode()) {
+    if (status.getCode() != TSStatusCode.LOAD_FILE_ERROR.getStatusCode()
+        // Ignore the error if it is caused by insufficient memory
+        || (status.getMessage() != null && status.getMessage().contains("memory"))) {
       return Optional.empty();
     }