Failed to execute bulk item?

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?

Not sure why this failure happens..., can you try and recreate it in a
standalone index operation? (Elasticsearch Platform — Find real-time answers at scale | Elastic).

On Thu, Apr 26, 2012 at 4:31 PM, sam mishra.sameek@gmail.com wrote:

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?