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 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.
For more options, visit https://groups.google.com/groups/opt_out.