You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2019/03/26 21:46:49 UTC
[accumulo] branch 1.9 updated: restore exception handling #949
#1005 (#1057)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch 1.9
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/1.9 by this push:
new e93cb7a restore exception handling #949 #1005 (#1057)
e93cb7a is described below
commit e93cb7ac55cac70197fe7df2b7208e1f0a16150d
Author: Keith Turner <kt...@apache.org>
AuthorDate: Tue Mar 26 17:46:44 2019 -0400
restore exception handling #949 #1005 (#1057)
---
.../org/apache/accumulo/tserver/log/TabletServerLogger.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
index d52d611..2ed699f 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java
@@ -302,6 +302,12 @@ public class TabletServerLogger {
}
}
+ try {
+ nextLog.offer(t, 12, TimeUnit.HOURS);
+ } catch (InterruptedException ex) {
+ // ignore
+ }
+
continue;
}
@@ -332,6 +338,12 @@ public class TabletServerLogger {
log.error("Failed to close WAL that failed to open: " + fileName, e);
}
+ try {
+ nextLog.offer(t, 12, TimeUnit.HOURS);
+ } catch (InterruptedException ex) {
+ // ignore
+ }
+
continue;
}