[2018-04-18T09:05:01,738][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,739][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,739][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,740][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,740][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,741][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,741][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeDisconnectedException[[SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected]]
org.elasticsearch.transport.NodeDisconnectedException: [SERVER3][10.0.0.3:9300][indices:data/write/bulk[s][r]] disconnected
[2018-04-18T09:05:01,742][WARN ][o.e.c.a.s.ShardStateAction] [SERVER1] [winlogbeat-6.1.2-2018.04.16][1] received shard failed for shard id [[winlogbeat-6.1.2-2018.04.16][1]], allocation id [aF_mHJp0Qf6CwS1-jiFPoA], primary term [3], message [failed to perform indices:data/write/bulk[s] on replica [winlogbeat-6.1.2-2018.04.16][1], node[m4g37E_rR56fgQa0iT0aRg], [R], s[STARTED], a[id=aF_mHJp0Qf6CwS1-jiFPoA]], failure [NodeNotConnectedException[[SERVER3][10.0.0.3:9300] Node not connected]]
org.elasticsearch.transport.NodeNotConnectedException: [SERVER3][10.0.0.3:9300] Node not connected
at org.elasticsearch.transport.TcpTransport.getConnection(TcpTransport.java:692) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.transport.TcpTransport.getConnection(TcpTransport.java:122) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.transport.TransportService.getConnection(TransportService.java:525) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:501) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.TransportReplicationAction.sendReplicaRequest(TransportReplicationAction.java:1188) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.TransportReplicationAction$ReplicasProxy.performOn(TransportReplicationAction.java:1152) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.ReplicationOperation.performOnReplica(ReplicationOperation.java:171) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.ReplicationOperation.performOnReplicas(ReplicationOperation.java:155) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.ReplicationOperation.execute(ReplicationOperation.java:122) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.TransportReplicationAction$AsyncPrimaryAction.onResponse(TransportReplicationAction.java:358) ~[elasticsearch-6.1.2.jar:6.1.2]
at org.elasticsearch.action.support.replication.TransportReplicationAction$AsyncPrimaryAction.onResponse(TransportReplicationAction.java:298) ~[elasticsearch-6.1.2.jar:6.1.2]