flink sink es execption

Mon, 18 Feb 2019 23:53:29 -0800 

es 5.x 
flink bulk sink
现象：运行几秒钟后抛异常
es数据可以正确插入
这个异常导致cpu上升
Caused by: org.elasticsearch.transport.SendRequestTransportException: 
[basedata03][10.10.2.15:9300][indices:data/write/bulk]
  at 
org.elasticsearch.transport.TransportService.sendRequestInternal(TransportService.java:531)
  at 
org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:465)
  at 
org.elasticsearch.action.TransportActionNodeProxy.execute(TransportActionNodeProxy.java:51)
  at 
org.elasticsearch.client.transport.TransportProxyClient.lambda$execute$0(TransportProxyClient.java:59)
  at 
org.elasticsearch.client.transport.TransportClientNodesService$RetryListener.onFailure(TransportClientNodesService.java:275)
  ... 8 common frames omitted
Caused by: org.elasticsearch.transport.NodeNotConnectedException: 
[basedata03][10.10.2.15:9300] Node not connected
  at org.elasticsearch.transport.TcpTransport.nodeChannel(TcpTransport.java:491)
  at org.elasticsearch.transport.TcpTransport.sendRequest(TcpTransport.java:921)
  at 
org.elasticsearch.transport.TransportService.sendRequestInternal(TransportService.java:520)
  ... 12 common frames omitted

回复