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

jiangtian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
24d1191a8e7 is described below

commit 24d1191a8e7c7e05cf92c5261a6a8f44ed67d45a
Author: Haonan <[email protected]>
AuthorDate: Tue Sep 24 09:52:15 2024 +0800

    Fix potential NPE when write FileTimeIndexCache (#13583)
    
    * Ignore the acceptable NPE then write FileTimeIndexCache
    
    * add channal != null
---
 .../utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java        | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java
index 3d88575ba68..30a8a24f4b7 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java
@@ -57,9 +57,11 @@ public class FileTimeIndexCacheWriter implements ILogWriter {
         // For UT env, logFile may not be created
         return;
       }
-      channel.write(logBuffer);
-      if (this.forceEachWrite) {
-        channel.force(true);
+      if (channel != null && channel.isOpen()) {
+        channel.write(logBuffer);
+        if (this.forceEachWrite) {
+          channel.force(true);
+        }
       }
     } catch (ClosedChannelException ignored) {
       logger.warn("someone interrupt current thread, so no need to do write 
for io safety");

Reply via email to