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: 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+unsubscr...@googlegroups.com.
To view this discussion on the web visit 
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.

Reply via email to