You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2015/11/21 23:30:33 UTC
[1/6] accumulo git commit: ACCUMULO-4060 Handle uncaught exceptions
in FATE repo runner threads.
Repository: accumulo
Updated Branches:
refs/heads/1.6 78522c4cd -> e82c3f3da
refs/heads/1.7 5947b4206 -> 1853d088e
refs/heads/master 0e1da5a58 -> 2b6e68b6a
ACCUMULO-4060 Handle uncaught exceptions in FATE repo runner threads.
Any RuntimeException propagated from the internals of the FATE
repo-runner threads will caught the thread to exit. This creates
a situation where the Master can be running but be unresponsive
to any pending FATE operations like creating a table.
Make sure that these exceptions are caught and suppressed to ensure
that FATE ops can always be handled while the master is running.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e82c3f3d
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e82c3f3d
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e82c3f3d
Branch: refs/heads/1.6
Commit: e82c3f3dab208478173e352635f87a96d72a38b2
Parents: 78522c4
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 16:53:11 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 16:58:26 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/e82c3f3d/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
diff --git a/fate/src/main/java/org/apache/accumulo/fate/Fate.java b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
index 493d441..52c7b2f 100644
--- a/fate/src/main/java/org/apache/accumulo/fate/Fate.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
@@ -38,6 +38,7 @@ public class Fate<T> {
private static final String RETURN_PROP = "return";
final private static Logger log = Logger.getLogger(Fate.class);
+ private final Logger runnerLog = Logger.getLogger(TransactionRunner.class);
private TStore<T> store;
private T environment;
@@ -91,6 +92,8 @@ public class Fate<T> {
}
}
}
+ } catch (Exception e) {
+ runnerLog.error("Uncaught exception in FATE runner thread.", e);
} finally {
store.unreserve(tid, deferTime);
}
[5/6] accumulo git commit: Merge branch '1.6' into 1.7
Posted by el...@apache.org.
Merge branch '1.6' into 1.7
Conflicts:
fate/src/main/java/org/apache/accumulo/fate/Fate.java
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/1853d088
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/1853d088
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/1853d088
Branch: refs/heads/1.7
Commit: 1853d088e855a0c3f9345f6509c292814dcc61bb
Parents: 5947b42 e82c3f3
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 17:28:15 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 17:28:15 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/1853d088/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
diff --cc fate/src/main/java/org/apache/accumulo/fate/Fate.java
index cf2ab73,52c7b2f..8a3aaf7
--- a/fate/src/main/java/org/apache/accumulo/fate/Fate.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
@@@ -41,7 -37,8 +41,8 @@@ public class Fate<T>
private static final String EXCEPTION_PROP = "exception";
private static final String RETURN_PROP = "return";
- final private static Logger log = Logger.getLogger(Fate.class);
- private final Logger runnerLog = Logger.getLogger(TransactionRunner.class);
+ final private static Logger log = LoggerFactory.getLogger(Fate.class);
++ private final Logger runnerLog = LoggerFactory.getLogger(TransactionRunner.class);
private TStore<T> store;
private T environment;
[2/6] accumulo git commit: ACCUMULO-4060 Handle uncaught exceptions
in FATE repo runner threads.
Posted by el...@apache.org.
ACCUMULO-4060 Handle uncaught exceptions in FATE repo runner threads.
Any RuntimeException propagated from the internals of the FATE
repo-runner threads will caught the thread to exit. This creates
a situation where the Master can be running but be unresponsive
to any pending FATE operations like creating a table.
Make sure that these exceptions are caught and suppressed to ensure
that FATE ops can always be handled while the master is running.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e82c3f3d
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e82c3f3d
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e82c3f3d
Branch: refs/heads/1.7
Commit: e82c3f3dab208478173e352635f87a96d72a38b2
Parents: 78522c4
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 16:53:11 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 16:58:26 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/e82c3f3d/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
diff --git a/fate/src/main/java/org/apache/accumulo/fate/Fate.java b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
index 493d441..52c7b2f 100644
--- a/fate/src/main/java/org/apache/accumulo/fate/Fate.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
@@ -38,6 +38,7 @@ public class Fate<T> {
private static final String RETURN_PROP = "return";
final private static Logger log = Logger.getLogger(Fate.class);
+ private final Logger runnerLog = Logger.getLogger(TransactionRunner.class);
private TStore<T> store;
private T environment;
@@ -91,6 +92,8 @@ public class Fate<T> {
}
}
}
+ } catch (Exception e) {
+ runnerLog.error("Uncaught exception in FATE runner thread.", e);
} finally {
store.unreserve(tid, deferTime);
}
[6/6] accumulo git commit: Merge branch '1.7'
Posted by el...@apache.org.
Merge branch '1.7'
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/2b6e68b6
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/2b6e68b6
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/2b6e68b6
Branch: refs/heads/master
Commit: 2b6e68b6a6966c4dc80b422aa9e7a1766936b7da
Parents: 0e1da5a 1853d08
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 17:29:57 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 17:29:57 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/2b6e68b6/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
[3/6] accumulo git commit: ACCUMULO-4060 Handle uncaught exceptions
in FATE repo runner threads.
Posted by el...@apache.org.
ACCUMULO-4060 Handle uncaught exceptions in FATE repo runner threads.
Any RuntimeException propagated from the internals of the FATE
repo-runner threads will caught the thread to exit. This creates
a situation where the Master can be running but be unresponsive
to any pending FATE operations like creating a table.
Make sure that these exceptions are caught and suppressed to ensure
that FATE ops can always be handled while the master is running.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e82c3f3d
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e82c3f3d
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e82c3f3d
Branch: refs/heads/master
Commit: e82c3f3dab208478173e352635f87a96d72a38b2
Parents: 78522c4
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 16:53:11 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 16:58:26 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/e82c3f3d/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
diff --git a/fate/src/main/java/org/apache/accumulo/fate/Fate.java b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
index 493d441..52c7b2f 100644
--- a/fate/src/main/java/org/apache/accumulo/fate/Fate.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
@@ -38,6 +38,7 @@ public class Fate<T> {
private static final String RETURN_PROP = "return";
final private static Logger log = Logger.getLogger(Fate.class);
+ private final Logger runnerLog = Logger.getLogger(TransactionRunner.class);
private TStore<T> store;
private T environment;
@@ -91,6 +92,8 @@ public class Fate<T> {
}
}
}
+ } catch (Exception e) {
+ runnerLog.error("Uncaught exception in FATE runner thread.", e);
} finally {
store.unreserve(tid, deferTime);
}
[4/6] accumulo git commit: Merge branch '1.6' into 1.7
Posted by el...@apache.org.
Merge branch '1.6' into 1.7
Conflicts:
fate/src/main/java/org/apache/accumulo/fate/Fate.java
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/1853d088
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/1853d088
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/1853d088
Branch: refs/heads/master
Commit: 1853d088e855a0c3f9345f6509c292814dcc61bb
Parents: 5947b42 e82c3f3
Author: Josh Elser <el...@apache.org>
Authored: Sat Nov 21 17:28:15 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Sat Nov 21 17:28:15 2015 -0500
----------------------------------------------------------------------
fate/src/main/java/org/apache/accumulo/fate/Fate.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/1853d088/fate/src/main/java/org/apache/accumulo/fate/Fate.java
----------------------------------------------------------------------
diff --cc fate/src/main/java/org/apache/accumulo/fate/Fate.java
index cf2ab73,52c7b2f..8a3aaf7
--- a/fate/src/main/java/org/apache/accumulo/fate/Fate.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/Fate.java
@@@ -41,7 -37,8 +41,8 @@@ public class Fate<T>
private static final String EXCEPTION_PROP = "exception";
private static final String RETURN_PROP = "return";
- final private static Logger log = Logger.getLogger(Fate.class);
- private final Logger runnerLog = Logger.getLogger(TransactionRunner.class);
+ final private static Logger log = LoggerFactory.getLogger(Fate.class);
++ private final Logger runnerLog = LoggerFactory.getLogger(TransactionRunner.class);
private TStore<T> store;
private T environment;