Updated Branches: refs/heads/master 069fb1afd -> b2adcaa3e
ACCUMULO-1812 translate ClosedChannelException into LogClosedException Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b2adcaa3 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b2adcaa3 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b2adcaa3 Branch: refs/heads/master Commit: b2adcaa3e405041ce300dc5b157c473cf91211fb Parents: 069fb1a Author: Eric Newton <eric.new...@gmail.com> Authored: Thu Oct 24 11:07:34 2013 -0400 Committer: Eric Newton <eric.new...@gmail.com> Committed: Thu Oct 24 11:07:48 2013 -0400 ---------------------------------------------------------------------- .../org/apache/accumulo/server/tabletserver/log/DfsLogger.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/b2adcaa3/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java ---------------------------------------------------------------------- diff --git a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java index 6d574b9..0b64d42 100644 --- a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java +++ b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java @@ -26,6 +26,7 @@ import java.io.DataOutputStream; import java.io.IOException; import java.io.OutputStream; import java.lang.reflect.Method; +import java.nio.channels.ClosedChannelException; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -407,6 +408,8 @@ public class DfsLogger { value.mutations = tabletMutations.getMutations(); write(key, value); } + } catch (ClosedChannelException ex) { + throw new LogClosedException(); } catch (Exception e) { log.error(e, e); work.exception = e;
