diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/BufferedRandomAccessFile.java b/hudi-common/src/main/java/org/apache/hudi/common/util/BufferedRandomAccessFile.java
index f40a46ef8..4eab19055 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/util/BufferedRandomAccessFile.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/util/BufferedRandomAccessFile.java
@@ -79,7 +79,7 @@ public final class BufferedRandomAccessFile extends RandomAccessFile {
    */
   public BufferedRandomAccessFile(File file, String mode) throws IOException {
     super(file, mode);
-    this.init(0);
+    this.init(DEFAULT_BUFFER_SIZE);
   }
 
   /**
@@ -102,7 +102,7 @@ public final class BufferedRandomAccessFile extends RandomAccessFile {
    */
   public BufferedRandomAccessFile(String name, String mode) throws IOException {
     super(name, mode);
-    this.init(0);
+    this.init(DEFAULT_BUFFER_SIZE);
   }
 
   /**
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/collection/DiskBasedMap.java b/hudi-common/src/main/java/org/apache/hudi/common/util/collection/DiskBasedMap.java
index f4b592478..56ef5c3d7 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/util/collection/DiskBasedMap.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/util/collection/DiskBasedMap.java
@@ -93,7 +93,7 @@ public final class DiskBasedMap<T extends Serializable, R extends Serializable>
     try {
       BufferedRandomAccessFile readHandle = randomAccessFile.get();
       if (readHandle == null) {
-        readHandle = new BufferedRandomAccessFile(filePath, "r");
+        readHandle = new BufferedRandomAccessFile(filePath, "r", BUFFER_SIZE);
         readHandle.seek(0);
         randomAccessFile.set(readHandle);
         openedAccessFiles.offer(readHandle);