restore exception handling #949 #1005 (#1057)

apache · Mar 26, 2019 · e93cb7a · e93cb7a
1 parent 07d6346
commit e93cb7a
Showing 1 changed file with 12 additions and 0 deletions.
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
@@ -302,6 +302,12 @@ public void run() {
               }
             }
 
+            try {
+              nextLog.offer(t, 12, TimeUnit.HOURS);
+            } catch (InterruptedException ex) {
+              // ignore
+            }
+
             continue;
           }
 
@@ -332,6 +338,12 @@ public void run() {
               log.error("Failed to close WAL that failed to open: " + fileName, e);
             }
 
+            try {
+              nextLog.offer(t, 12, TimeUnit.HOURS);
+            } catch (InterruptedException ex) {
+              // ignore
+            }
+
             continue;
           }