Hi
when i am building index using rabbitmq river, multiple threads are
publishing message into same queue with same index but different index
type,i am getting following exception :
[2012-04-26 18:31:57,636][DEBUG][action.bulk ] [Coral]
[idx_masterdatabase][2]: Failed to execute bulk item (index) [index
{[idx_masterdatabase][type_test2][1], source[{ "type_test2" :{"id":
1,"Description":"A computer is a programmable machine designed to
sequentially and automatically carry out a sequence of arithmetic or
logical operations"}}]}]
java.lang.NullPointerException
at
org.apache.lucene.util.AttributeSource.cloneAttributes(AttributeSource.java:
542)
at
org.apache.lucene.analysis.shingle.ShingleFilter.getNextToken(ShingleFilter.java:
356)
at
org.apache.lucene.analysis.shingle.ShingleFilter.shiftInputWindow(ShingleFilter.java:
415)
at
org.apache.lucene.analysis.shingle.ShingleFilter.incrementToken(ShingleFilter.java:
284)
at
org.apache.lucene.analysis.snowball.SnowballFilter.incrementToken(SnowballFilter.java:
76)
at
org.apache.lucene.analysis.fr.ElisionFilter.incrementToken(ElisionFilter.java:
121)
at
org.elasticsearch.index.analysis.phonetic.PhoneticFilter.incrementToken(PhoneticFilter.java:
61)
at
org.apache.lucene.index.DocInverterPerField.processFields(DocInverterPerField.java:
132)
at
org.apache.lucene.index.DocFieldProcessorPerThread.processDocument(DocFieldProcessorPerThread.java:
248)
at
org.apache.lucene.index.DocumentsWriter.updateDocument(DocumentsWriter.java:
701)
at org.apache.lucene.index.IndexWriter.addDocument(IndexWriter.java:
2042)
at
org.elasticsearch.index.engine.robin.RobinEngine.innerIndex(RobinEngine.java:
459)
at
org.elasticsearch.index.engine.robin.RobinEngine.index(RobinEngine.java:
374)
at
org.elasticsearch.index.shard.service.InternalIndexShard.index(InternalIndexShard.java:
292)
at
org.elasticsearch.action.bulk.TransportShardBulkAction.shardOperationOnPrimary(TransportShardBulkAction.java:
131)
at
org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction
$AsyncShardOperationAction.performOnPrimary(TransportShardReplicationOperationAction.java:
418)
at
org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction
$AsyncShardOperationAction.access
$100(TransportShardReplicationOperationAction.java:233)
at
org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction
$AsyncShardOperationAction
$1.run(TransportShardReplicationOperationAction.java:331)
at java.util.concurrent.ThreadPoolExecutor
$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor
$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
This Exception is not thrown by piece of code only prints in elastic
server log, thus i am not able to catch it.Is there any way to handle
this exception in client program.?
And what could be possible reason for the above exception?