You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/09/20 12:49:15 UTC
(iotdb) branch do-not-convert-when-receiver-load-oom created (now 3a84621adc6)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch do-not-convert-when-receiver-load-oom
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 3a84621adc6 Pipe: Avoid type conversion if error on receiver is caused by insufficient memory
This branch includes the following new commits:
new 3a84621adc6 Pipe: Avoid type conversion if error on receiver is caused by insufficient memory
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Pipe: Avoid type conversion if error on receiver is caused by insufficient memory
Posted by ro...@apache.org.
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 <ro...@apache.org>
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();
}