ElasticSearch 0.16: Already flushing exception


(pcdinh) #1

Hi,

I got a lot of exceptions as follows in elasticsearch.log

[2011-05-06 10:17:42,198][DEBUG][action.admin.indices.flush] [Enigma]
[poidev][1], node[9kyQaFDoSe6_DC-6WYQBZA], [P], s[STARTED]: Failed to
execute
[org.elasticsearch.action.admin.indices.flush.FlushRequest@b0ffd6]
org.elasticsearch.index.engine.FlushNotAllowedEngineException: [poidev]
[1] Already flushing...
at
org.elasticsearch.index.engine.robin.RobinEngine.flush(RobinEngine.java:
661)
at
org.elasticsearch.index.shard.service.InternalIndexShard.flush(InternalIndexShard.java:
417)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
114)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
50)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.performOperation(TransportBroadcastOperationAction.java:
238)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.access
$200(TransportBroadcastOperationAction.java:126)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction$1.run(TransportBroadcastOperationAction.java:
195)
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)
[2011-05-06 10:17:42,804][DEBUG][action.admin.indices.flush] [Enigma]
[poidev][4], node[9kyQaFDoSe6_DC-6WYQBZA], [P], s[STARTED]: Failed to
execute
[org.elasticsearch.action.admin.indices.flush.FlushRequest@c1c6c3]
org.elasticsearch.index.engine.FlushNotAllowedEngineException: [poidev]
[4] Already flushing...
at
org.elasticsearch.index.engine.robin.RobinEngine.flush(RobinEngine.java:
661)
at
org.elasticsearch.index.shard.service.InternalIndexShard.flush(InternalIndexShard.java:
417)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
114)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
50)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.performOperation(TransportBroadcastOperationAction.java:
238)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.access
$200(TransportBroadcastOperationAction.java:126)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction$1.run(TransportBroadcastOperationAction.java:
195)
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)

I am doing bulk index using pyes. Is it a bug or just a mistake wih my
code?

Regards,

Dinh


(Shay Banon) #2

You can ignore that. You issue a flush request, and its already in the process of flushing for that shard, so its not executing.
On Friday, May 6, 2011 at 1:23 PM, pcdinh wrote:

Hi,

I got a lot of exceptions as follows in elasticsearch.log

[2011-05-06 10:17:42,198][DEBUG][action.admin.indices.flush] [Enigma]
[poidev][1], node[9kyQaFDoSe6_DC-6WYQBZA], [P], s[STARTED]: Failed to
execute
[org.elasticsearch.action.admin.indices.flush.FlushRequest@b0ffd6]
org.elasticsearch.index.engine.FlushNotAllowedEngineException: [poidev]
[1] Already flushing...
at
org.elasticsearch.index.engine.robin.RobinEngine.flush(RobinEngine.java:
661)
at
org.elasticsearch.index.shard.service.InternalIndexShard.flush(InternalIndexShard.java:
417)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
114)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
50)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.performOperation(TransportBroadcastOperationAction.java:
238)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.access
$200(TransportBroadcastOperationAction.java:126)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction$1.run(TransportBroadcastOperationAction.java:
195)
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)
[2011-05-06 10:17:42,804][DEBUG][action.admin.indices.flush] [Enigma]
[poidev][4], node[9kyQaFDoSe6_DC-6WYQBZA], [P], s[STARTED]: Failed to
execute
[org.elasticsearch.action.admin.indices.flush.FlushRequest@c1c6c3]
org.elasticsearch.index.engine.FlushNotAllowedEngineException: [poidev]
[4] Already flushing...
at
org.elasticsearch.index.engine.robin.RobinEngine.flush(RobinEngine.java:
661)
at
org.elasticsearch.index.shard.service.InternalIndexShard.flush(InternalIndexShard.java:
417)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
114)
at
org.elasticsearch.action.admin.indices.flush.TransportFlushAction.shardOperation(TransportFlushAction.java:
50)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.performOperation(TransportBroadcastOperationAction.java:
238)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction.access
$200(TransportBroadcastOperationAction.java:126)
at
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction
$AsyncBroadcastAction$1.run(TransportBroadcastOperationAction.java:
195)
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)

I am doing bulk index using pyes. Is it a bug or just a mistake wih my
code?

Regards,

Dinh


(system) #3