(iotdb) branch dev/1.3 updated: [To dev/1.3] Active Load: Ignore java.io.UncheckedIOException exceptions thrown during the file scanning process. (#16705) (#16726)

[jiangtian]

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

jiangtian 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 926f1959af1 [To dev/1.3] Active Load: Ignore 
java.io.UncheckedIOException exceptions thrown during the file scanning 
process. (#16705) (#16726)
926f1959af1 is described below

commit 926f1959af179ebe56e21507b2b577122ad28c6b
Author: Zhenyu Luo <zhe...@apache.org>
AuthorDate: Mon Nov 10 18:32:34 2025 +0800

    [To dev/1.3] Active Load: Ignore java.io.UncheckedIOException exceptions 
thrown during the file scanning process. (#16705) (#16726)
    
    * Active Load: Ignore java.io.UncheckedIOException exceptions thrown during 
the file scanning process. (#16705)
    
    (cherry picked from commit 2de3bb6f534bb94f816f893c9091b0c95fb1d2a8)
    
    * spotless
---
 .../iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java       | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
index 9ac840bf91d..d029fbdecc8 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
@@ -32,6 +32,7 @@ import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.io.IOException;
+import java.io.UncheckedIOException;
 import java.nio.file.FileVisitResult;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -115,6 +116,8 @@ public class ActiveLoadDirScanner extends 
ActiveLoadScheduledExecutorService {
               .limit(currentAllowedPendingSize)
               .forEach(
                   file -> activeLoadTsFileLoader.tryTriggerTsFileLoad(file, 
isGeneratedByPipe));
+        } catch (UncheckedIOException e) {
+          LOGGER.debug("The file has been deleted. Ignore this exception.");
         } catch (final Exception e) {
           LOGGER.warn("Exception occurred during scanning dir: {}", 
listeningDir, e);
         }