cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r964564 - /cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java
Date Thu, 15 Jul 2010 20:16:55 GMT
Author: jbellis
Date: Thu Jul 15 20:16:55 2010
New Revision: 964564

URL: http://svn.apache.org/viewvc?rev=964564&view=rev
Log:
switch CFOutputFormatTest client to Framed mode.  patch by jbellis

Modified:
    cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java

Modified: cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java?rev=964564&r1=964563&r2=964564&view=diff
==============================================================================
--- cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java
(original)
+++ cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java
Thu Jul 15 20:16:55 2010
@@ -45,6 +45,7 @@ import org.apache.hadoop.mapreduce.Outpu
 import org.apache.hadoop.util.ToolRunner;
 import org.apache.thrift.TException;
 import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.transport.TFramedTransport;
 import org.apache.thrift.transport.TSocket;
 import org.apache.thrift.transport.TTransport;
 import org.junit.After;
@@ -125,8 +126,7 @@ public class ColumnFamilyOutputFormatTes
     {
         /* Establish a thrift connection to the cassandra instance */
         TSocket socket = new TSocket(DatabaseDescriptor.getListenAddress().getHostName(),
DatabaseDescriptor.getRpcPort());
-        TTransport transport;
-        transport = socket;
+        TTransport transport = new TFramedTransport(socket);
         TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport, false, false);
         Cassandra.Client cassandraClient = new Cassandra.Client(binaryProtocol);
         transport.open();



Mime
View raw message