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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 7e181d55a31 [To dev/1.3] Load: Optimized the exception error message 
of convertion to tablet (#16499) (#16530)
7e181d55a31 is described below

commit 7e181d55a31c39b24551d556c0d58a3e476b1c57
Author: Caideyipi <[email protected]>
AuthorDate: Tue Sep 30 16:05:12 2025 +0800

    [To dev/1.3] Load: Optimized the exception error message of convertion to 
tablet (#16499) (#16530)
---
 .../LoadTreeStatementDataTypeConvertExecutionVisitor.java    | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
index f0658bdbee8..1ca4338607c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
@@ -117,7 +117,7 @@ public class 
LoadTreeStatementDataTypeConvertExecutionVisitor
             tabletRawReqSizes.clear();
 
             if (!handleTSStatus(result, loadTsFileStatement)) {
-              return Optional.empty();
+              return Optional.of(result);
             }
 
             tabletRawReqs.add(tabletRawReq);
@@ -127,7 +127,9 @@ public class 
LoadTreeStatementDataTypeConvertExecutionVisitor
         } catch (final Exception e) {
           LOGGER.warn(
               "Failed to convert data type for LoadTsFileStatement: {}.", 
loadTsFileStatement, e);
-          return Optional.empty();
+          return Optional.of(
+              loadTsFileStatement.accept(
+                  LoadTsFileDataTypeConverter.STATEMENT_EXCEPTION_VISITOR, e));
         }
       }
 
@@ -144,12 +146,14 @@ public class 
LoadTreeStatementDataTypeConvertExecutionVisitor
           tabletRawReqSizes.clear();
 
           if (!handleTSStatus(result, loadTsFileStatement)) {
-            return Optional.empty();
+            return Optional.of(result);
           }
         } catch (final Exception e) {
           LOGGER.warn(
               "Failed to convert data type for LoadTsFileStatement: {}.", 
loadTsFileStatement, e);
-          return Optional.empty();
+          return Optional.of(
+              loadTsFileStatement.accept(
+                  LoadTsFileDataTypeConverter.STATEMENT_EXCEPTION_VISITOR, e));
         }
       }
     } finally {

Reply via email to