[HUDI-1133] Tune buffer sizes for the diskbased external spillable map
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 f40a46e..4eab190 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 BufferedRandomAccessFile(File file, String mode) throws IOException {
super(file, mode);
- this.init(0);
+ this.init(DEFAULT_BUFFER_SIZE);
}
/**
@@ -102,7 +102,7 @@
*/
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 f4b5924..56ef5c3 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 @@
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);
