This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch do-not-convert-when-receiver-load-oom in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3a84621adc67fea9b1952506d9cf9c7d7feb4467 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Sep 20 20:49:05 2024 +0800 Pipe: Avoid type conversion if error on receiver is caused by insufficient memory --- .../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(); }
