You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2016/07/29 04:15:00 UTC
hbase git commit: HBASE-16289 AsyncProcess stuck messages need to
print region/server
Repository: hbase
Updated Branches:
refs/heads/master 66fb697f8 -> ab9df0a01
HBASE-16289 AsyncProcess stuck messages need to print region/server
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ab9df0a0
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ab9df0a0
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ab9df0a0
Branch: refs/heads/master
Commit: ab9df0a0145535c24c60ea2f03b2d5701fd229de
Parents: 66fb697
Author: Yu Li <li...@apache.org>
Authored: Fri Jul 29 11:21:42 2016 +0800
Committer: Yu Li <li...@apache.org>
Committed: Fri Jul 29 11:21:42 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/hadoop/hbase/client/AsyncProcess.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/ab9df0a0/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java
index 812e4bf..4514560 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java
@@ -1682,7 +1682,11 @@ class AsyncProcess {
if (!hasWait) { // Only log if wait is infinite.
if (now > lastLog + 10000) {
lastLog = now;
- LOG.info("#" + id + ", waiting for " + currentInProgress + " actions to finish");
+ LOG.info("#" + id + ", waiting for " + currentInProgress
+ + " actions to finish on table: " + tableName);
+ if (currentInProgress <= thresholdToLogUndoneTaskDetails) {
+ logDetailsOfUndoneTasks(currentInProgress);
+ }
}
}
synchronized (actionsInProgress) {