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");