Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-17991 Add more details about compaction queue on /dump (Guangxu Cheng)

This commit is contained in:
tedyu 2017-05-04 08:24:58 -07:00
parent 2de6b051f6
commit 52119200bc
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java
View File

@ -420,6 +420,7 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi
private int queuedPriority; private int queuedPriority;
private ThreadPoolExecutor parent; private ThreadPoolExecutor parent;
private User user; private User user;
private long time;
public CompactionRunner(Store store, Region region, public CompactionRunner(Store store, Region region,
CompactionContext compaction, ThreadPoolExecutor parent, User user) { CompactionContext compaction, ThreadPoolExecutor parent, User user) {
@ -431,12 +432,14 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi
? store.getCompactPriority() : compaction.getRequest().getPriority(); ? store.getCompactPriority() : compaction.getRequest().getPriority();
this.parent = parent; this.parent = parent;
this.user = user; this.user = user;
this.time = System.currentTimeMillis();
} }
@Override @Override
public String toString() { public String toString() {
return (this.compaction != null) ? ("Request = " + compaction.getRequest()) return (this.compaction != null) ? ("Request = " + compaction.getRequest())
: ("Store = " + store.toString() + ", pri = " + queuedPriority); : ("regionName = " + region.toString() + ", storeName = " + store.toString() +
", priority = " + queuedPriority + ", time = " + time);
} }
private void doCompaction(User user) { private void doCompaction(User user) {