why Does the bulk index not work?

[lester015]

Dear fhussonnois,
I using this IndexBatchBolt class which can realize bulk indexs into elasticsearch,the storm submit the topology was successfully, the storm UI as flows;

I see the work log and found the bulkUpdateIndexes method not executed successfully. the work-port.log as bellows:
2016-12-22T10:18:15.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] executeTickTuple is beginning ....source: __system:-1, stream: __tick, id: {}, [1]
2016-12-22T10:18:15.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] bulkUpdateIndexes is beginning ....
2016-12-22T10:18:15.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] queue size ....0
2016-12-22T10:18:15.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] inputs.size ...0
2016-12-22T10:18:16.710+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] executeTickTuple is beginning ....source: __system:-1, stream: __tick, id: {}, [1]
2016-12-22T10:18:16.710+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] bulkUpdateIndexes is beginning ....
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] queue size ....0
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] inputs.size ...0
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] executeTickTuple is beginning ....source: __system:-1, stream: __tick, id: {}, [1]
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] bulkUpdateIndexes is beginning ....
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] queue size ....0
2016-12-22T10:18:16.711+0800 c.g.f.s.e.b.IndexBatchBolt [INFO] inputs.size ...0

why Does the inputs.size is zero?
List inputs = new ArrayList<>(queue.size());
LOGGER.info("queue size ...." + queue.size());

thanks,
Levi

[lester015]

this is initiation,I found the this method:
protected void bulkUpdateIndexes( ) {
queue.drainTo(inputs);
LOGGER.info("queue drainTo ...." + inputs.size());
}

After the drainTo inputs, there is no records in the inputs. I don't know the reason!