CassandraRiver.java:149 contains:
logger.info("Starting thread with {} keys", this.keys.rowColumnMap.size());
where rowColumnMap is a map, and may be empty thats why this error comes
And at first i build that river module normally and install it as a plugin
in ES.
But when i ran script:
curl -XPUT 'localhost:9200/_river/userinfo/_meta' -d '{
"type" : "cassandra",
"cassandra" : {
"cluster_name" : "Test Cluster",
"keyspace" : "topic_space",
"column_family" : "users",
"batch_size" : 100,
"hosts" : "localhost:9160"
},
"index" : {
"index" : "userinfo",
"type" : "users"
}
}'
same error comes in ES console, same as i have copied from maven console.
and it also not fetching data from cassandra to ES.
--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/elasticsearch/0bc5a111-0562-46ff-a640-9b9241638887%40googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.
