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

jackietien pushed a commit to branch ty/fixFetchNPE
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 4ac7078565759aa4c13b4ca68f2a3becefdc6dd8
Author: JackieTien97 <[email protected]>
AuthorDate: Mon Jun 23 19:56:42 2025 +0800

    Avoid NPE in fetch FI Info
---
 .../db/queryengine/execution/fragment/FragmentInstanceContext.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContext.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContext.java
index 4d0a0a07752..55df223db17 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContext.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContext.java
@@ -417,7 +417,7 @@ public class FragmentInstanceContext extends QueryContext {
 
     for (Throwable t : failures) {
       Throwable failure = getRootCause(t);
-      if (failureCause.isEmpty()) {
+      if (failureCause.isEmpty() && failure.getMessage() != null) {
         failureCause = failure.getMessage();
       }
       
failureInfoList.add(FragmentInstanceFailureInfo.toFragmentInstanceFailureInfo(failure));

Reply via email to