You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2018/02/05 20:38:26 UTC

hbase git commit: HBASE-19940 TestMetaShutdownHandler flakey

Repository: hbase
Updated Branches:
  refs/heads/master 9f2149f17 -> 6307689a6


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/6307689a
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/6307689a
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/6307689a

Branch: refs/heads/master
Commit: 6307689a6e03f30d7d1490fbf9fe9dff9138a7ff
Parents: 9f2149f
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:37:48 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/6307689a/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();
           }
         }