Repository: hbase Updated Branches: refs/heads/branch-1 ab3ec9477 -> a15c44574 refs/heads/branch-1.3 b7d2e98a6 -> 8ca843e9a refs/heads/branch-1.4 9824dd623 -> 95684c161 refs/heads/branch-2 99714da30 -> 777f3e88e refs/heads/branch-2.0 7b07a8bca -> 7b36f2b0b refs/heads/branch-2.1 1b66839bc -> daeec8657 refs/heads/master 7be97980f -> 5a1e02b6d
HBASE-20935 HStore.removeCompactedFiles should log in case it is unable to delete a file (Vishal Khandelwal) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5a1e02b6 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5a1e02b6 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5a1e02b6 Branch: refs/heads/master Commit: 5a1e02b6dcf27bb2825bab3d97f50e981f98f91d Parents: 7be9798 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 15:58:05 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/5a1e02b6/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 db868fd..ca6e591 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 @@ -2605,6 +2605,11 @@ public class HStore implements Store, HeapSize, StoreConfigInformation, Propagat filesToRemove.add(file); // Only add the length if we successfully added the file to `filesToRemove` storeFileSizes.add(length); + } 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 {}",
