使用Elasticsearch的Java API时可能出现的错误

2 年 ago

科, 雅

2 minutes

当使用Java API将数十万条大量数据投入ElasticSearch时，会出现以下错误。
从内容来看，这个错误似乎是处理时间超过5秒时发生的。
然而，数据本身似乎已经正确注册了。

– 错误内容 –

2015年6月4日下午2:42:02，org.elasticsearch.plugins.PluginsService信息：[Storm]已加载的插件为[]，站点为[]。
2015年6月4日下午2:43:36，org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler信息：[Storm]无法获取节点信息[#transport#-1][or-00154.bbq.net-marketing.co.jp][inet[/192.168.33.10:9300]]，断开连接…
org.elasticsearch.transport.ReceiveTimeoutTransportException: [][inet[/192.168.33.10:9300]][cluster:monitor/nodes/info] 请求ID [18] 超时[5002ms]
at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:366)
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)

2015年6月4日下午2:43:46，org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler 进行采样操作时出现错误。
信息：[Storm] 获取节点信息失败，节点地址为[#transport#-1][or-00154.bbq.net-marketing.co.jp][inet[/192.168.33.10:9300]]，正在断开连接…
org.elasticsearch.transport.ReceiveTimeoutTransportException: [][inet[/192.168.33.10:9300]][cluster:monitor/nodes/info] 请求ID为[19]的请求在[5039ms]后超时
at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:366)
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)

2015年6月4日下午2点43分56秒，[Storm]获取节点信息失败[#transport#-1][or-00154.bbq.net-marketing.co.jp][inet[/192.168.33.10:9300]]，断开连接…
org.elasticsearch.transport.ReceiveTimeoutTransportException：[][inet[/192.168.33.10:9300]][cluster:monitor/nodes/info]请求[20]在[5001ms]后超时
在org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:366)
在java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
在java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
在java.lang.Thread.run(Thread.java:745)

2015年6月4日下午2:44:06，org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler doSample 消息：[Storm] 获取节点[#transport#-1][or-00154.bbq.net-marketing.co.jp][inet[/192.168.33.10:9300]]信息失败，正在断开连接…
org.elasticsearch.transport.ReceiveTimeoutTransportException: [][inet[/192.168.33.10:9300]][cluster:monitor/nodes/info] 请求ID [21] 在[5001ms]后超时。
at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:366)
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)

2015年6月4日下午2点44分16秒，org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler doSample发生异常。
[Storm]无法获取节点信息[#transport#-1][or-00154.bbq.net-marketing.co.jp][inet[/192.168.33.10:9300]]，正在断开连接…
org.elasticsearch.transport.ReceiveTimeoutTransportException:[] [inet[/192.168.33.10:9300]][cluster:monitor/nodes/info]请求ID[22]在[5001ms]后超时。
在org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:366)执行。
在java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)执行。
在java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)执行。
在java.lang.Thread.run(Thread.java:745)执行。