You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2021/01/27 13:10:03 UTC

[accumulo] branch 1.10 updated: Make UnloadTabletHandler log before waiting (#1881)

This is an automated email from the ASF dual-hosted git repository.

mmiller pushed a commit to branch 1.10
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1.10 by this push:
     new ed97eac  Make UnloadTabletHandler log before waiting (#1881)
ed97eac is described below

commit ed97eac76da47f711f8f901810cc9d4d8fb27214
Author: Mike Miller <mm...@apache.org>
AuthorDate: Wed Jan 27 08:09:54 2021 -0500

    Make UnloadTabletHandler log before waiting (#1881)
    
    * If a tablet is in the process of being opened, the UnloadTabletHandler
    will wait for a tablet to be removed from the list before proceeding
    with the unload.  This could take a long time so log info before waiting.
    * Fix Typo in UnloadTabletHandler
---
 .../src/main/java/org/apache/accumulo/tserver/TabletServer.java        | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
index 73bc58f..e141de9 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java
@@ -2220,6 +2220,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable {
       synchronized (openingTablets) {
         while (openingTablets.contains(extent)) {
           try {
+            log.info("Waiting for tablet {} to finish opening before unloading.", extent);
             openingTablets.wait();
           } catch (InterruptedException e) {}
         }
@@ -2246,7 +2247,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable {
       } catch (Throwable e) {
 
         if ((t.isClosing() || t.isClosed()) && e instanceof IllegalStateException) {
-          log.debug("Failed to unload tablet {} ... it was alread closing or closed : {}", extent,
+          log.debug("Failed to unload tablet {} ... it was already closing or closed : {}", extent,
               e.getMessage());
         } else {
           log.error("Failed to close tablet {}... Aborting migration", extent, e);