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 2012/03/22 19:48:30 UTC
svn commit: r1303976 - in /incubator/accumulo/branches/1.4:
conf/examples/3GB/native-standalone/accumulo-site.xml
conf/examples/3GB/standalone/accumulo-site.xml
src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
Author: ecn
Date: Thu Mar 22 18:48:29 2012
New Revision: 1303976
URL: http://svn.apache.org/viewvc?rev=1303976&view=rev
Log:
ACCUMULO-486 return logger connections to the transport pool
Modified:
incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml
incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
Modified: incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml (original)
+++ incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml Thu Mar 22 18:48:29 2012
@@ -61,7 +61,7 @@
<property>
<name>tserver.cache.index.size</name>
- <value>100M</value>
+ <value>512M</value>
</property>
<property>
Modified: incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml (original)
+++ incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml Thu Mar 22 18:48:29 2012
@@ -61,7 +61,7 @@
<property>
<name>tserver.cache.index.size</name>
- <value>100M</value>
+ <value>512M</value>
</property>
<property>
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java Thu Mar 22 18:48:29 2012
@@ -34,7 +34,6 @@ import org.apache.accumulo.server.conf.S
import org.apache.accumulo.server.security.SecurityConstants;
import org.apache.log4j.Logger;
import org.apache.thrift.TException;
-import org.apache.thrift.TServiceClient;
import org.apache.thrift.transport.TTransportException;
/**
@@ -124,10 +123,12 @@ public class RemoteLogger {
public synchronized void close() throws NoSuchLogIDException, LoggerClosedException, TException {
try {
- client.close(null, logFile.id);
+ if (client != null)
+ client.close(null, logFile.id);
} finally {
- TServiceClient c = (TServiceClient) client;
- c.getInputProtocol().getTransport().close();
+ MutationLogger.Iface tmp = client;
+ client = null;
+ ThriftUtil.returnClient(tmp);
}
}