Skip to content

Commit 0946f43

Browse files
author
XuQianJin-Stars
committed
improve spillableMapBasePath disk directory is full
1 parent bde6137 commit 0946f43

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,8 @@ protected HoodieMergedLogRecordScanner(FileSystem fs, String basePath, List<Stri
9494
instantRange, withOperationField,
9595
forceFullScan, partitionName, internalSchema);
9696
try {
97-
String[] dirs = FileIOUtils.getConfiguredLocalDirs();
98-
spillableMapBasePath = dirs.length > 0 ? dirs[0] : spillableMapBasePath;
97+
String[] localDirs = FileIOUtils.getConfiguredLocalDirs();
98+
spillableMapBasePath = localDirs.length > 0 ? localDirs[0] : spillableMapBasePath;
9999
// Store merged records for all versions for this log file, set the in-memory footprint to maxInMemoryMapSize
100100
this.records = new ExternalSpillableMap<>(maxMemorySizeInBytes, spillableMapBasePath, new DefaultSizeEstimator(),
101101
new HoodieRecordSizeEstimator(readerSchema), diskMapType, isBitCaskDiskMapCompressionEnabled);

0 commit comments

Comments
 (0)