HBASE-20935 HStore.removeCompactedFiles should log in case it is unable to delete a file (Vishal Khandelwal)
Conflicts: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/daeec865 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/daeec865 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/daeec865 Branch: refs/heads/branch-2.1 Commit: daeec8657e3f2fe8307e270967e2e3db0339c46c Parents: 1b66839 Author: Andrew Purtell <apurt...@apache.org> Authored: Tue Jul 31 15:58:05 2018 -0700 Committer: Andrew Purtell <apurt...@apache.org> Committed: Tue Jul 31 16:06:15 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/hbase/regionserver/HStore.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/daeec865/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java index 6670339..06d6455 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java @@ -2554,6 +2554,11 @@ public class HStore implements Store, HeapSize, StoreConfigInformation, Propagat r.close(true); // Just close and return filesToRemove.add(file); + } else { + LOG.info("Can't archive compacted file " + file.getPath() + + " because of either isCompactedAway = " + file.isCompactedAway() + + " or file has reference, isReferencedInReads = " + file.isReferencedInReads() + + ", skipping for now."); } } catch (Exception e) { LOG.error("Exception while trying to close the compacted store file {}",