Added closing of the FileChannel and associated InputStream after cre…

…ation of the MMapTable instance
dain · Jun 26, 2019 · 435ceef · 435ceef
1 parent 8a89086
commit 435ceef
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/leveldb/src/main/java/org/iq80/leveldb/impl/TableCache.java b/leveldb/src/main/java/org/iq80/leveldb/impl/TableCache.java
@@ -127,6 +127,8 @@ private TableAndFile(File databaseDir, long fileNumber, UserComparator userCompa
                 FileChannel fileChannel = fis.getChannel();
                 if (Iq80DBFactory.USE_MMAP) {
                     table = new MMapTable(tableFile.getAbsolutePath(), fileChannel, userComparator, verifyChecksums);
+                    // We can close the channel and input stream as the mapping does not need them
+                    Closeables.closeQuietly(fis);
                 }
                 else {
                     table = new FileChannelTable(tableFile.getAbsolutePath(), fileChannel, userComparator, verifyChecksums);