[5/6] accumulo git commit: Merge branch '1.6' into 1.7
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 ElserAuthored: Sat Nov 21 17:28:15 2015 -0500 Committer: Josh Elser 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 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 store; private T environment;
[2/6] accumulo git commit: ACCUMULO-4060 Handle uncaught exceptions in FATE repo runner threads.
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 ElserAuthored: Sat Nov 21 16:53:11 2015 -0500 Committer: Josh Elser 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 { 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 store; private T environment; @@ -91,6 +92,8 @@ public class Fate { } } } +} catch (Exception e) { + runnerLog.error("Uncaught exception in FATE runner thread.", e); } finally { store.unreserve(tid, deferTime); }
[3/6] accumulo git commit: ACCUMULO-4060 Handle uncaught exceptions in FATE repo runner threads.
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 ElserAuthored: Sat Nov 21 16:53:11 2015 -0500 Committer: Josh Elser 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 { 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 store; private T environment; @@ -91,6 +92,8 @@ public class Fate { } } } +} catch (Exception e) { + runnerLog.error("Uncaught exception in FATE runner thread.", e); } finally { store.unreserve(tid, deferTime); }
[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 ElserAuthored: Sat Nov 21 16:53:11 2015 -0500 Committer: Josh Elser 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 { 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 store; private T environment; @@ -91,6 +92,8 @@ public class Fate { } } } +} 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'
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 ElserAuthored: Sat Nov 21 17:29:57 2015 -0500 Committer: Josh Elser 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 --
[4/6] accumulo git commit: Merge branch '1.6' into 1.7
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 ElserAuthored: Sat Nov 21 17:28:15 2015 -0500 Committer: Josh Elser 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 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 store; private T environment;