Author: jbellis Date: Tue Jul 27 04:05:45 2010 New Revision: 979518 URL: http://svn.apache.org/viewvc?rev=979518&view=rev Log: fix TBinaryProtocol instantiation in CFOF. 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=979518&r1=979517&r2=979518&view=diff ============================================================================== --- cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java (original) +++ cassandra/trunk/test/unit/org/apache/cassandra/hadoop/ColumnFamilyOutputFormatTest.java Tue Jul 27 04:05:45 2010 @@ -127,7 +127,7 @@ public class ColumnFamilyOutputFormatTes /* Establish a thrift connection to the cassandra instance */ TSocket socket = new TSocket(DatabaseDescriptor.getListenAddress().getHostName(), DatabaseDescriptor.getRpcPort()); TTransport transport = new TFramedTransport(socket); - TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport, false, false); + TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport); Cassandra.Client cassandraClient = new Cassandra.Client(binaryProtocol); transport.open(); thriftClient = cassandraClient;