You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2018/07/31 23:21:40 UTC
[7/7] hbase git commit: HBASE-20935 HStore.removeCompactedFiles
should log in case it is unable to delete a file (Vishal Khandelwal)
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/8ca843e9
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8ca843e9
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8ca843e9
Branch: refs/heads/branch-1.3
Commit: 8ca843e9a5c732195d61835b0e3e459dafdcbd2f
Parents: b7d2e98
Author: Andrew Purtell <ap...@apache.org>
Authored: Tue Jul 31 15:58:05 2018 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Tue Jul 31 16:15:41 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/8ca843e9/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 a30e827..49efd82 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
@@ -2743,6 +2743,11 @@ public class HStore implements Store {
r.close(true);
// Just close and return
filesToRemove.add(file);
+ } else {
+ LOG.info("Can't archive compacted file " + file.getPath()
+ + " because of either isCompactedAway = " + r.isCompactedAway()
+ + " or file has reference, isReferencedInReads = " + r.isReferencedInReads()
+ + ", skipping for now.");
}
} catch (Exception e) {
LOG.error(