I can confirm running same problem.
Tried ConfigHelper.setThriftMaxMessageLengthInMb();, and tuning server
side, reducing/increasing batch size.
Here's stacktrace from Hadoop/Cassandra, maybe it could give a hint:
Caused by: org.apache.thrift.protocol.TProtocolException: Message length
Tried to isolate the issue in testing environment,
What I currently have:
That's a setup for test:
CREATE KEYSPACE cascading_cassandra WITH replication = {'class' :
'SimpleStrategy', 'replication_factor' : 1};
USE cascading_cassandra;
CREATE TABLE libraries (emitted_at timestamp, additional_info
I created my column family like this from the CLI-
create column family profile
with key_validation_class = 'UTF8Type'
and comparator = 'UTF8Type'
and default_validation_class = 'UTF8Type'
and column_metadata = [
{column_name : account, validation_class : 'UTF8Type'}
I am working with Datastax java-driver. And I am trying to retrieve few
columns from the database basis on the input that is being passed to the
below method-
public MapString, String getAttributes(final String userId, final
CollectionString attributeNames) {
String query=SELECT
getColumnDefinitions only returns meta data, to get the data, use the
iterator to navigate the rows
IteratorRow it = result.iterator();
while (it.hasNext()) {
Row r = it.next();
//do stuff with row
}
On 04/21/2013 12:02 AM, Techy Teck wrote:
I am working with Datastax java-driver.
Thanks Dave for the suggestion. I have all my columns name in this
collection-
*final CollectionString attributeNames*
*
*
And all my results back in this resultset-
*ResultSet result =
CassandraDatastaxConnection.getSession().execute(query);*
*
*
Now I need to
You have the collection attributeNames, just iterate it
IteratorRow it = result.iterator();
while(it.hasNext()){
Row row = it.next();
for(String column : attributeNames) {
//not sure how to put the columnName and columnValue that
came back from
