flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "董鹏" <dongp...@imdada.cn>
Subject flink sink es execption
Date Tue, 19 Feb 2019 03:08:51 GMT
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
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message