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

[rong]

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 f87de7f9d25 Pipe: Avoid type conversion if error on receiver is caused 
by insufficient memory (#13569)
f87de7f9d25 is described below

commit f87de7f9d25e9f06e2fd30dab4b45a21045b3057
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Sun Sep 22 23:34:30 2024 +0800

    Pipe: Avoid type conversion if error on receiver is caused by insufficient 
memory (#13569)
---
 .../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 868785ec8fb..498bce53340 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();
     }