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);