cascading.tap.TapException: unable to store value with key: [full_new_tk_ml_exact_name_partial_address_comparator, composite, z:LEG:00000031033]
	at beenverified.tap.ESNativeOutputCollector.collect(ESNativeOutputCollector.java:119)
	at beenverified.tap.ESNativeOutputCollector.collect(ESNativeOutputCollector.java:29)
	at beenverified.tap.ESBaseScheme.sink(ESBaseScheme.java:70)
	at cascading.tap.Tap.sink(Tap.java:266)
	at cascading.flow.stack.SinkReducerStackElement.operateSink(SinkReducerStackElement.java:124)
	at cascading.flow.stack.SinkReducerStackElement.collect(SinkReducerStackElement.java:79)
	at cascading.pipe.Every$EveryBufferHandler$1.collect(Every.java:482)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:71)
	at beenverified.export.assembly.PersonZoneToCompositePersonAssembly$ZonePersonToCompositePersonBuffer.operate(PersonZoneToCompositePersonAssembly.java:72)
	at cascading.pipe.Every$EveryBufferHandler.operate(Every.java:534)
	at cascading.flow.stack.EveryBufferReducerStackElement.collect(EveryBufferReducerStackElement.java:89)
	at cascading.flow.stack.GroupReducerStackElement.operateGroup(GroupReducerStackElement.java:74)
	at cascading.flow.stack.GroupReducerStackElement.collect(GroupReducerStackElement.java:58)
	at cascading.flow.stack.FlowReducerStack.reduce(FlowReducerStack.java:169)
	at cascading.flow.FlowReducer.reduce(FlowReducer.java:75)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:467)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:415)
	at org.apache.hadoop.mapred.Child.main(Child.java:170)
Caused by: java.util.concurrent.ExecutionException: org.elasticsearch.transport.RemoteTransportException: [Atlas][inet[/10.104.123.193:9300]][indices/index/shard/index]
	at org.elasticsearch.common.util.concurrent.AbstractFuture$Sync.complete(AbstractFuture.java:318)
	at org.elasticsearch.common.util.concurrent.AbstractFuture$Sync.setException(AbstractFuture.java:295)
	at org.elasticsearch.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:127)
	at org.elasticsearch.action.support.AdapterActionFuture.onFailure(AdapterActionFuture.java:87)
	at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$2.handleException(TransportShardReplicationOperationAction.java:309)
	at org.elasticsearch.transport.netty.MessageChannelHandler.handleException(MessageChannelHandler.java:176)
	at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:157)
	at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:100)
	at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
	at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:545)
	at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:754)
	at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:302)
	at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:317)
	at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299)
	at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:214)
	at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
	at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:545)
	at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:540)
	at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:274)
	at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:261)
	at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:350)
	at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:281)
	at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:201)
	at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.elasticsearch.common.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46)
	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:619)
Caused by: org.elasticsearch.transport.RemoteTransportException: [Atlas][inet[/10.104.123.193:9300]][indices/index/shard/index]
Caused by: org.elasticsearch.action.support.replication.ReplicationShardOperationFailedException: [full_new_tk_ml_exact_name_partial_address_comparator][22]
	at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction.performOnPrimary(TransportShardReplicationOperationAction.java:396)
	at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction.access$400(TransportShardReplicationOperationAction.java:212)
	at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1.run(TransportShardReplicationOperationAction.java:282)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
	at java.lang.Thread.run(Thread.java:636)
Caused by: org.elasticsearch.index.engine.CreateFailedEngineException: [full_new_tk_ml_exact_name_partial_address_comparator][22] Create failed for [composite#z:LEG:00000031033]
	at org.elasticsearch.index.engine.robin.RobinEngine.create(RobinEngine.java:251)
	at org.elasticsearch.index.shard.service.InternalIndexShard.create(InternalIndexShard.java:232)
	at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:142)
	at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:62)
	at org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction.performOnPrimary(TransportShardReplicationOperationAction.java:385)
	... 5 more
Caused by: java.io.FileNotFoundException: /mnt/elasticsearch/work/default/nodes/0/indices/full_new_tk_ml_exact_name_partial_address_comparator/22/index/_g1.fdt (Too many open files)
	at java.io.RandomAccessFile.open(Native Method)
	at java.io.RandomAccessFile.(RandomAccessFile.java:233)
	at org.apache.lucene.store.SimpleFSDirectory$SimpleFSIndexOutput.(SimpleFSDirectory.java:180)
	at org.apache.lucene.store.NIOFSDirectory.createOutput(NIOFSDirectory.java:74)
	at org.elasticsearch.index.store.support.AbstractStore$StoreDirectory.createOutput(AbstractStore.java:182)
	at org.apache.lucene.index.FieldsWriter.(FieldsWriter.java:65)
	at org.apache.lucene.index.StoredFieldsWriter.initFieldsWriter(StoredFieldsWriter.java:66)
	at org.apache.lucene.index.StoredFieldsWriter.finishDocument(StoredFieldsWriter.java:144)
	at org.apache.lucene.index.StoredFieldsWriter$PerDoc.finish(StoredFieldsWriter.java:192)
	at org.apache.lucene.index.DocumentsWriter$WaitQueue.writeDocument(DocumentsWriter.java:1554)
	at org.apache.lucene.index.DocumentsWriter$WaitQueue.add(DocumentsWriter.java:1573)
	at org.apache.lucene.index.DocumentsWriter.finishDocument(DocumentsWriter.java:1150)
	at org.apache.lucene.index.DocumentsWriter.updateDocument(DocumentsWriter.java:827)
	at org.apache.lucene.index.DocumentsWriter.addDocument(DocumentsWriter.java:797)
	at org.apache.lucene.index.IndexWriter.addDocument(IndexWriter.java:1981)
	at org.elasticsearch.index.engine.robin.RobinEngine.create(RobinEngine.java:244)
	... 9 more