Client Errors Connecting To Elasticsearch

12:20:54.255 [ThreadJob] INFO  o.a.samza.container.TaskInstance - SystemStreamPartition [kafka, ledger, 0] is catched up.
12:20:54.262 [ThreadJob] INFO  ledger.elastic.job - context:  #object[org.apache.samza.container.TaskInstance$$anon$1 0x2c1eb155 org.apache.samza.container.TaskInstance$$anon$1@2c1eb155]
12:20:54.267 [ThreadJob] INFO  ledger.elastic.job - envelope:  {:class org.apache.samza.system.IncomingMessageEnvelope, :key nil, :message :thing, :offset 14, :size 0, :system-stream-partition {:class org.apache.samza.system.SystemStreamPartition, :partition {:class org.apache.samza.Partition, :partition-id 0}, :stream ledger, :system kafka, :system-stream {:class org.apache.samza.system.SystemStream, :stream ledger, :system kafka}}}
12:20:54.268 [ThreadJob] INFO  ledger.elastic.job - collector:  #object[org.apache.samza.task.TaskInstanceCollector 0x49021938 org.apache.samza.task.TaskInstanceCollector@49021938]
12:20:54.269 [ThreadJob] INFO  ledger.elastic.job - coordinator:  #object[org.apache.samza.task.ReadableCoordinator 0x10594fc1 org.apache.samza.task.ReadableCoordinator@10594fc1]
12:21:45.097 [ThreadJob] ERROR o.a.s.s.e.ElasticsearchSystemProducer - None of the configured nodes are available: []
12:21:45.097 [ThreadJob] ERROR o.a.s.s.e.ElasticsearchSystemProducer - Unable to send message from TaskName-Partition 0 to system elasticsearch.
12:21:45.100 [ThreadJob] ERROR o.a.samza.container.SamzaContainer - Caught exception in process loop.
org.apache.samza.SamzaException: Unable to send message from TaskName-Partition 0 to system elasticsearch.
    at org.apache.samza.system.elasticsearch.ElasticsearchSystemProducer.flush(ElasticsearchSystemProducer.java:184)
    at org.apache.samza.system.SystemProducers$$anonfun$flush$2.apply(SystemProducers.scala:64)
    at org.apache.samza.system.SystemProducers$$anonfun$flush$2.apply(SystemProducers.scala:64)
    at scala.collection.Iterator$class.foreach(Iterator.scala:727)
    at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
    at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
    at org.apache.samza.system.SystemProducers.flush(SystemProducers.scala:64)
    at org.apache.samza.task.TaskInstanceCollector.flush(TaskInstanceCollector.scala:70)
    at org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:182)
    at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcVJ$sp$7.apply(RunLoop.scala:162)
    at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcVJ$sp$7.apply(RunLoop.scala:162)
    at scala.collection.Iterator$class.foreach(Iterator.scala:727)
    at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
    at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
    at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply$mcVJ$sp(RunLoop.scala:162)
    at org.apache.samza.util.TimerUtils$class.updateTimerAndGetDuration(TimerUtils.scala:51)
    at org.apache.samza.container.RunLoop.updateTimerAndGetDuration(RunLoop.scala:35)
    at org.apache.samza.container.RunLoop.commit(RunLoop.scala:157)
    at org.apache.samza.container.RunLoop.run(RunLoop.scala:76)
    at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:553)
    at org.apache.samza.job.local.ThreadJob$$anon$1.run(ThreadJob.scala:42)
Caused by: org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []
    at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:279)
    at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:198)
    at org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:106)
    at org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:97)
    at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:158)
    at org.elasticsearch.client.transport.TransportClient.bulk(TransportClient.java:351)
    at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:314)
    at org.elasticsearch.action.bulk.BulkProcessor.flush(BulkProcessor.java:376)
    at org.apache.samza.system.elasticsearch.ElasticsearchSystemProducer.flush(ElasticsearchSystemProducer.java:175)
    ... 20 common frames omitted
12:21:45.101 [ThreadJob] INFO  o.a.samza.container.SamzaContainer - Shutting down.
12:21:45.101 [ThreadJob] INFO  o.a.samza.container.SamzaContainer - Shutting down consumer multiplexer.
12:21:45.101 [ThreadJob] INFO  o.a.samza.system.kafka.BrokerProxy - Shutting down BrokerProxy for 192.168.99.100:9092
12:21:45.102 [ThreadJob] INFO  o.a.samza.system.kafka.BrokerProxy - closing simple consumer...
12:21:45.295 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at 192.168.99.100:9092 for client samza_consumer-ledger_elastic_connector-1-1462908044125-21] INFO  o.a.samza.system.kafka.BrokerProxy - Shutting down due to interrupt.
12:21:45.296 [ThreadJob] INFO  o.a.samza.container.SamzaContainer - Shutting down task instance stream tasks.
12:21:45.297 [ThreadJob] DEBUG o.a.samza.container.TaskInstance - Shutting down stream task for taskName: Partition 0
12:21:45.298 [ThreadJob] INFO  o.a.samza.container.SamzaContainer - Shutting down task instance stores.
12:21:45.299 [ThreadJob] DEBUG o.a.samza.container.TaskInstance - Shutting down storage manager for taskName: Partition 0
12:21:45.301 [ThreadJob] INFO  o.a.samza.container.SamzaContainer - Shutting down producer multiplexer.
12:21:45.302 [ThreadJob] ERROR o.a.s.s.e.ElasticsearchSystemProducer - Unable to send message from TaskName-Partition 0 to system elasticsearch.
12:21:45.303 [ThreadJob] ERROR org.apache.samza.job.local.ThreadJob - Failing job with exception.