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 @dadoonet | @elasticsearchfr Le 8 janvier 2014 at 11:06:42, shamsul haque ([email protected]) a écrit: 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") Map<String, Object> couchSettings = (Map<String, Object>) 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 [email protected]. To view this discussion on the web visit 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. -- 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/etPan.52cd23e2.12200854.1449b%40MacBook-Air-de-David.local. For more options, visit https://groups.google.com/groups/opt_out.
