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;