You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/10/24 17:07:44 UTC
git commit: ACCUMULO-1812 translate ClosedChannelException into
LogClosedException
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 <er...@gmail.com>
Authored: Thu Oct 24 11:07:34 2013 -0400
Committer: Eric Newton <er...@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;