This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch ht/cp_0926 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 99b1e99fedb26e0bf617c37991e0b6f05cb4e09c 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");
