diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java
index e9a33f6cb28..da3da42f35a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java
@@ -178,15 +178,11 @@ public class SnapshotFileCache implements Stoppable {
* at that point, cache will still think the file system contains that file and return
* true, even if it is no longer present (false positive). However, if the file never was
* on the filesystem, we will never find it and always return false.
- * @param files file to check, NOTE: Relies that files are loaded from hdfs before method is
- * called (NOT LAZY)
+ * @param files file to check
* @return unReferencedFiles the collection of files that do not have snapshot references
* @throws IOException if there is an unexpected error reaching the filesystem.
*/
- // XXX this is inefficient to synchronize on the method, when what we really need to guard against
- // is an illegal access to the cache. Really we could do a mutex-guarded pointer swap on the
- // cache, but that seems overkill at the moment and isn't necessarily a bottleneck.
- public Iterable getUnreferencedFiles(Iterable files,
+ public Iterable getUnreferencedFiles(List files,
final SnapshotManager snapshotManager) throws IOException {
List unReferencedFiles = Lists.newArrayList();
List snapshotsInProgress = null;
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotHFileCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotHFileCleaner.java
index a300cbbce68..bcd129afc21 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotHFileCleaner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotHFileCleaner.java
@@ -20,7 +20,10 @@ package org.apache.hadoop.hbase.master.snapshot;
import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
+import java.util.List;
import java.util.Map;
+import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
@@ -64,8 +67,15 @@ public class SnapshotHFileCleaner extends BaseHFileCleanerDelegate {
@Override
public Iterable getDeletableFiles(Iterable files) {
+ // The Iterable is lazy evaluated, so if we just pass this Iterable in, we will access the HFile
+ // storage inside the snapshot lock, which could take a lot of time (for example, several
+ // seconds), and block all other operations, especially other cleaners.
+ // So here we convert it to List first, to force it evaluated before calling
+ // getUnreferencedFiles, so we will not hold snapshot lock for a long time.
+ List filesList =
+ StreamSupport.stream(files.spliterator(), false).collect(Collectors.toList());
try {
- return cache.getUnreferencedFiles(files, master.getSnapshotManager());
+ return cache.getUnreferencedFiles(filesList, master.getSnapshotManager());
} catch (CorruptedSnapshotException cse) {
LOG.debug("Corrupted in-progress snapshot file exception, ignored ", cse);
} catch (IOException e) {