issue solved:
in river code, when fetching data from Casandra it
uses HFactory.createRangeSlicesQuery(keyspace, STR, STR, STR); to get data
and the table which i was using to get data contain Primary Key as int id,
after changing that to text it starts pulling data from Cassandra to ES.
Thanks
I have downloaded river from: https://github.com/eBay/cassandra-river
change the settings in file: CassandraRiver.java as per my Cassandra
setting:
if (riverSettings.settings().containsKey(cassandra)) {
@SuppressWarnings(unchecked)
MapString, Object couchSettings = (MapString,
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
1 change which i have made in that cassandra-river project is to change the
casandra jar version from 1.3 to 2.0.3 in pox.xml as i am using Cassandra
2.0.4
Any idea whats going wrong?
--
You received this message because you are subscribed to the Google Groups
elasticsearch group.
To
ok, Thanks for pointing this.
--
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 elasticsearch+unsubscr...@googlegroups.com.
To view this discussion on the web
