accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ibe...@apache.org
Subject [accumulo] branch master updated: ACCUMULO-4854 : DfsLogger exceptions (#616) Removed translation of ClosedChannelException to a LogClosedException in the write method as that is done by callers of the method.
Date Tue, 04 Sep 2018 17:51:23 GMT
This is an automated email from the ASF dual-hosted git repository.

ibella pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/master by this push:
     new 4b3273b  ACCUMULO-4854 : DfsLogger exceptions (#616)    Removed translation of ClosedChannelException
to a LogClosedException in the write method as that is done by callers of the method.
4b3273b is described below

commit 4b3273bd61e3fbc792069a07fdae37e59151f1a2
Author: Ivan Bella <ivan@bella.name>
AuthorDate: Sat Aug 25 21:07:44 2018 -0400

    ACCUMULO-4854 : DfsLogger exceptions (#616)
       Removed translation of ClosedChannelException to a LogClosedException in the write
method as that is done by callers of the method.
---
 .../main/java/org/apache/accumulo/tserver/log/DfsLogger.java   | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
index b0f3229..9f50621 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java
@@ -553,13 +553,9 @@ public class DfsLogger implements Comparable<DfsLogger> {
   }
 
   private synchronized void write(LogFileKey key, LogFileValue value) throws IOException
{
-    try {
-      key.write(encryptingLogFile);
-      value.write(encryptingLogFile);
-      encryptingLogFile.flush();
-    } catch (ClosedChannelException e) {
-      throw new LogClosedException();
-    }
+    key.write(encryptingLogFile);
+    value.write(encryptingLogFile);
+    encryptingLogFile.flush();
   }
 
   public LoggerOperation log(long seq, int tid, Mutation mutation, Durability durability)


Mime
View raw message