Elasticsearchのデータ格納について

こんにちは
javaでファイルを取得してからデータを格納しているのですが
Kibanaで確認してみるとほとんどデータが保存されてません

ログを確認してみるとたまにエラー?を吐き出しているせいですか?
エラー?ログはこんな感じです

org.elasticsearch.transport.SendRequestTransportException: [Cain][inet[/:9300]][internal:cluster/shard/started]
at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:286)
at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:249)
at org.elasticsearch.cluster.action.shard.ShardStateAction.shardStarted(ShardStateAction.java:126)
at org.elasticsearch.cluster.action.shard.ShardStateAction.shardStarted(ShardStateAction.java:114)
at org.elasticsearch.indices.cluster.IndicesClusterStateService$2.onRecoveryDone(IndicesClusterStateService.java:746)
at org.elasticsearch.index.gateway.IndexShardGatewayService$1.run(IndexShardGatewayService.java:139)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.elasticsearch.transport.TransportException: TransportService is closed stopped can't send request
at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:270)
... 8 more

解決方法とか教えてください。