(iotdb) branch rc/1.3.3 updated: Pipe: Avoid type conversion if error on receiver is caused by insufficient memory (#13569) (#13723)

[ro...@apache.org]

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

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


The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
     new 9cf36284d14 Pipe: Avoid type conversion if error on receiver is caused by insufficient memory (#13569) (#13723)
9cf36284d14 is described below

commit 9cf36284d14d53b2bb4cbff13a0d5e25214c32a4
Author: V_Galaxy <vg...@apache.org>
AuthorDate: Sat Oct 12 12:41:19 2024 +0800

    Pipe: Avoid type conversion if error on receiver is caused by insufficient memory (#13569) (#13723)
    
    Co-authored-by: Steve Yurong Su <ro...@apache.org>
---
 .../visitor/PipeStatementDataTypeConvertExecutionVisitor.java         | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
index b4ad6a6da46..d2d12402783 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
@@ -83,7 +83,9 @@ public class PipeStatementDataTypeConvertExecutionVisitor
   @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();
     }