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:28:02 -07:00
parent a5f52360f6
commit dd321c4a35
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

@ -460,6 +460,7 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi
private int queuedPriority;
private ThreadPoolExecutor parent;
private User user;
private long time;
public CompactionRunner(Store store, Region region,
CompactionContext compaction, ThreadPoolExecutor parent, User user) {
@ -471,12 +472,14 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi
? store.getCompactPriority() : compaction.getRequest().getPriority();
this.parent = parent;
this.user = user;
this.time = System.currentTimeMillis();
}
@Override
public String toString() {
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) {