# Cassandra river plugin installation issue **URL:** \ **Category:** Elasticsearch\ **Created:** [January 8, 2014, 10:06am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138 "2014-01-08T10:06:36Z")\ **Posts on this page:** 12\ **Page:** 1
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [January 8, 2014, 10:06am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/1 "2014-01-08T10:06:36Z")
I have downloaded river from: [https://github.com/eBay/cassandra-river](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") Map\ couchSettings = (Map\) settings.settings().get("cassandra"); this.clusterName = XContentMapValues.nodeStringValue(couchSettings.get("cluster\_name"), "Test Cluster"); this.keyspace = XContentMapValues.nodeStringValue(couchSettings.get("keyspace"), "topic\_space"); this.columnFamily = XContentMapValues.nodeStringValue(couchSettings.get("column\_family"), "users"); this.batchSize = XContentMapValues.nodeIntegerValue(couchSettings.get("batch\_size"), 1000); this.hosts = XContentMapValues.nodeStringValue(couchSettings.get("hosts"), "localhost:9160"); this.username = XContentMapValues.nodeStringValue(couchSettings.get("username"), "USERNAME"); this.password = XContentMapValues.nodeStringValue(couchSettings.get("password"), "P$$WD"); } else { /\* \* Set default values \*/ this.clusterName = "Test Cluster"; this.keyspace = "topic\_space"; this.columnFamily = "users"; this.batchSize = 1000; this.hosts = "localhost:9160"; this.username = "USERNAME"; this.password = "P$$WD"; } when i build maven using given command, mvn clean package in TEST mvn log it shows: * * * ## T E S T S Running org.elasticsearch.river.cassandra.CassandraRiverIntegrationTest Configuring TestNG with: org.apache.maven.surefire.testng.conf.TestNG652Configurator@67eaf25d Exception in thread "Queue-Indexer-thread-0" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-2" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-5" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-4" java.lang.NullPointerException i tried to do same after installing plugin in ES, it shows same error continuously. Anybody have any idea, whats going wrong with my setup?? -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/ef16f8fa-3145-43be-87ce-e8f53060938f%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/ef16f8fa-3145-43be-87ce-e8f53060938f%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [January 8, 2014, 10:09am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/2 "2014-01-08T10:09:38Z")
Why do you build your own version of the Cassandra river? You don't need to do that to use a river, right? That said, what is line CassandraRiver.java:149 -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 8 janvier 2014 at 11:06:42, shamsul haque ([shams.hq@gmail.com](mailto:shams.hq@gmail.com)) a écrit: I have downloaded river from: [https://github.com/eBay/cassandra-river](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") Map\ couchSettings = (Map\) settings.settings().get("cassandra"); this.clusterName = XContentMapValues.nodeStringValue(couchSettings.get("cluster\_name"), "Test Cluster"); this.keyspace = XContentMapValues.nodeStringValue(couchSettings.get("keyspace"), "topic\_space"); this.columnFamily = XContentMapValues.nodeStringValue(couchSettings.get("column\_family"), "users"); this.batchSize = XContentMapValues.nodeIntegerValue(couchSettings.get("batch\_size"), 1000); this.hosts = XContentMapValues.nodeStringValue(couchSettings.get("hosts"), "localhost:9160"); this.username = XContentMapValues.nodeStringValue(couchSettings.get("username"), "USERNAME"); this.password = XContentMapValues.nodeStringValue(couchSettings.get("password"), "P$$WD"); } else { /\* \* Set default values \*/ this.clusterName = "Test Cluster"; this.keyspace = "topic\_space"; this.columnFamily = "users"; this.batchSize = 1000; this.hosts = "localhost:9160"; this.username = "USERNAME"; this.password = "P$$WD"; } when i build maven using given command, mvn clean package in TEST mvn log it shows: * * * ## T E S T S Running org.elasticsearch.river.cassandra.CassandraRiverIntegrationTest Configuring TestNG with: org.apache.maven.surefire.testng.conf.TestNG652Configurator@67eaf25d Exception in thread "Queue-Indexer-thread-0" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-2" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-5" java.lang.NullPointerException at org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Exception in thread "Queue-Indexer-thread-4" java.lang.NullPointerException i tried to do same after installing plugin in ES, it shows same error continuously. Anybody have any idea, whats going wrong with my setup?? -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/ef16f8fa-3145-43be-87ce-e8f53060938f%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/ef16f8fa-3145-43be-87ce-e8f53060938f%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.52cd23e2.12200854.1449b%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.52cd23e2.12200854.1449b%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [January 8, 2014, 10:21am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/3 "2014-01-08T10:21:21Z")
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 [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/0bc5a111-0562-46ff-a640-9b9241638887%40googlegroups.com](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](https://groups.google.com/groups/opt_out). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [January 8, 2014, 10:26am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/4 "2014-01-08T10:26:56Z")
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 unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/3f8867fd-5f92-47a5-bf6b-5f4b2f5306ee%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/3f8867fd-5f92-47a5-bf6b-5f4b2f5306ee%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [January 8, 2014, 10:27am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/5 "2014-01-08T10:27:18Z")
So probably CassandraCFData cassandraData = db.getCFData(columnFamily, start, 1000); did not get any data from Cassandra? Never played with this plugin either Cassandra so I'm afraid I can't help more here! -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 8 janvier 2014 at 11:21:26, shamsul haque ([shams.hq@gmail.com](mailto:shams.hq@gmail.com)) a écrit: 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 [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/0bc5a111-0562-46ff-a640-9b9241638887%40googlegroups.com](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](https://groups.google.com/groups/opt_out). -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.52cd2806.109cf92e.1449b%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.52cd2806.109cf92e.1449b%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [January 8, 2014, 10:35am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/6 "2014-01-08T10:35:04Z")
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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/69213f6c-0e23-4a8d-bbf8-f9423d7200b3%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/69213f6c-0e23-4a8d-bbf8-f9423d7200b3%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [January 9, 2014, 11:35am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/7 "2014-01-09T11:35:26Z")
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 -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/050a535b-990b-4dd7-9af9-6caea0e6d4a5%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/050a535b-990b-4dd7-9af9-6caea0e6d4a5%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![AKhan](https://avatars.discourse-cdn.com/v4/letter/a/34f0e0/32.png) [@AKhan](https://discuss.elastic.co/u/AKhan)\ **Post date:** [February 4, 2014, 1:43pm UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/8 "2014-02-04T13:43:21Z")
Shamsul Haque, I am also getting the same error on Elastic Search console even though the type of id is string not int in my case. Any clue ? On Wednesday, January 8, 2014 11:06:36 AM UTC+1, shamsul haque wrote: > I have downloaded river from: [GitHub - eBay/cassandra-river: Cassandra river for Elastic search.](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") > Map\ couchSettings = (Map\) > settings.settings().get("cassandra"); > this.clusterName = > XContentMapValues.nodeStringValue(couchSettings.get("cluster\_name"), "Test > Cluster"); > this.keyspace = > XContentMapValues.nodeStringValue(couchSettings.get("keyspace"), > "topic\_space"); > this.columnFamily = > XContentMapValues.nodeStringValue(couchSettings.get("column\_family"), > "users"); > this.batchSize = > XContentMapValues.nodeIntegerValue(couchSettings.get("batch\_size"), 1000); > this.hosts = > XContentMapValues.nodeStringValue(couchSettings.get("hosts"), > "localhost:9160"); > this.username = > XContentMapValues.nodeStringValue(couchSettings.get("username"), > "USERNAME"); > this.password = > XContentMapValues.nodeStringValue(couchSettings.get("password"), "P$$WD"); > } else { > /\* > \* Set default values > \*/ > this.clusterName = "Test Cluster"; > this.keyspace = "topic\_space"; > this.columnFamily = "users"; > this.batchSize = 1000; > this.hosts = "localhost:9160"; > this.username = "USERNAME"; > this.password = "P$$WD"; > } > > when i build maven using given command, mvn clean package in TEST mvn log > it shows: > > * * * > > ## T E S T S > > Running org.elasticsearch.river.cassandra.CassandraRiverIntegrationTest > Configuring TestNG with: > org.apache.maven.surefire.testng.conf.TestNG652Configurator@67eaf25d > Exception in thread "Queue-Indexer-thread-0" java.lang.NullPointerException > at > org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > Exception in thread "Queue-Indexer-thread-2" java.lang.NullPointerException > at > org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > Exception in thread "Queue-Indexer-thread-5" java.lang.NullPointerException > at > org.elasticsearch.river.cassandra.CassandraRiver$Indexer.run(CassandraRiver.java:149) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > Exception in thread "Queue-Indexer-thread-4" java.lang.NullPointerException > > i tried to do same after installing plugin in ES, it shows same error > continuously. > Anybody have any idea, whats going wrong with my setup?? -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/281251a1-7226-477b-8c75-1d5934336d8e%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/281251a1-7226-477b-8c75-1d5934336d8e%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [February 5, 2014, 6:05am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/9 "2014-02-05T06:05:05Z")
> The issue is with Hector API, i have posted an issue in Hector API issue > > > link [https://github.com/hector-client/hector/issues/649](https://github.com/hector-client/hector/issues/649) . I have > > changed river implementation for getting data from Cassandra by Hector API > > to Cassandra Java Driver. -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/4a0426b1-b735-4185-a9d4-050ba63f02eb%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/4a0426b1-b735-4185-a9d4-050ba63f02eb%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![Abhishek\_Mukherjee](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/abhishek_mukherjee/32/1477_2.png) [@Abhishek\_Mukherjee](https://discuss.elastic.co/u/Abhishek_Mukherjee)\ **Post date:** [June 12, 2014, 5:45am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/10 "2014-06-12T05:45:34Z")
Is the Hector API issue fixed? I have setup the ebay/cassandra river and it shows 2 documents inside. However I cannot search them. I get an timed out exception. I suspect this is again from Hector API because of the H before timedoutexception. :{"error":"_H_TimedOutException[TimedOutException()]; nested: TimedOutException; ","node":{"id":"11vByNw4QPKKLrtUx-vkjw","name":"Krang","transport\_address":"inet[/192.168.1.103:9300]"}} On Wednesday, February 5, 2014 11:35:05 AM UTC+5:30, Shams Haque wrote: > The issue is with Hector API, i have posted an issue in Hector API issue > > > > link [https://github.com/hector-client/hector/issues/649](https://github.com/hector-client/hector/issues/649) . I have > > > changed river implementation for getting data from Cassandra by Hector API > > > to Cassandra Java Driver. -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/6eb46de3-09c6-4e3c-af78-a2ba805339bb%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/6eb46de3-09c6-4e3c-af78-a2ba805339bb%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![shamsul\_haque](https://avatars.discourse-cdn.com/v4/letter/s/b9bd4f/32.png) [@shamsul\_haque](https://discuss.elastic.co/u/shamsul_haque)\ **Post date:** [June 20, 2014, 7:48pm UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/11 "2014-06-20T19:48:17Z")
Hi, The issue was not with Hector API, issue has been fixed by using "WITH COMPACT STORAGE" when creating column families in Cassandra. Here i have posted it: > -- 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+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/9de84b4d-0d99-4483-bd1e-5f9471c0b97d%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/9de84b4d-0d99-4483-bd1e-5f9471c0b97d%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 1:20am UTC](https://discuss.elastic.co/t/cassandra-river-plugin-installation-issue/15138/12 "2017-07-06T01:20:52Z")