You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/02/06 12:46:54 UTC
[05/50] hbase git commit: HBASE-19940 TestMetaShutdownHandler flakey
HBASE-19940 TestMetaShutdownHandler flakey
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7723a3d6
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7723a3d6
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7723a3d6
Branch: refs/heads/HBASE-19397-branch-2
Commit: 7723a3d60d9c13a3f0919cf7b435e1bae73d54a8
Parents: a1600c1
Author: Michael Stack <st...@apache.org>
Authored: Mon Feb 5 12:37:48 2018 -0800
Committer: Michael Stack <st...@apache.org>
Committed: Mon Feb 5 12:38:51 2018 -0800
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/util/JVMClusterUtil.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/7723a3d6/hbase-server/src/main/java/org/apache/hadoop/hbase/util/JVMClusterUtil.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/JVMClusterUtil.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/JVMClusterUtil.java
index a85e89e..172c170 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/JVMClusterUtil.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/JVMClusterUtil.java
@@ -296,7 +296,15 @@ public class JVMClusterUtil {
if (!atLeastOneLiveServer) break;
for (RegionServerThread t : regionservers) {
if (t.isAlive()) {
- LOG.warn("RegionServerThreads taking too long to stop, interrupting");
+ LOG.warn("RegionServerThreads taking too long to stop, interrupting; thread dump " +
+ "if > three attempts");
+ if (i > 3) {
+ try {
+ Threads.threadDumpingIsAlive(t.getRegionServer().getThread());
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
t.interrupt();
}
}