我目前正在使用elasticsearch, logstash和kibana。
我遇到了一个异常,我无法通过。
首先是我在浏览器中输入ip:9200/_cluster/health后得到的结果。
{
"cluster_name":"mr-cluster",
"status":"yellow",
"timed_out":false,
"number_of_nodes":1,
"number_of_data_nodes":1,
"active_primary_shards":5,
"active_shards":5,
"relocating_shards":0,
"initializing_shards":0,
"unassigned_shards":5
}
这是kibana请求弹性搜索时得到的结果
Remote Address:ip:9200
Request ip:9200/_all/_search
Request Method:POST
Status Code:200 OK
直到现在看起来还好…
我的logstash配置文件:
input {
gelf {
port => "5000"
}
udp {
port => "5001"
}
}
output {
file {
path => "/home/g/stdout.log"
}
elasticsearch {
cluster => "mr-cluster"
codec => "json"
}
}
很简单,当我只使用一个文件作为输出,它工作完美,logstash工作。问题是,当我想使用elasticsearch作为输出,没有任何工作了(事件文件输出),我从elasticsearch得到这个异常。我已经在谷歌上搜索了几个小时了,还是没有找到解决办法。
这里有一个例外:
[2014-05-21 09:18:35,060][WARN ][http.netty ] [mr-node-elasticsearch] Caught exception while handling client http traffic, closing connection [id: 0x27d0ccce, /0:0:0:0:0:0:0:1:44164 => /0:0:0:0:0:0:0:1:9200]
java.lang.IllegalArgumentException: empty text
at org.elasticsearch.common.netty.handler.codec.http.HttpVersion.<init>(HttpVersion.java:97)
at org.elasticsearch.common.netty.handler.codec.http.HttpVersion.valueOf(HttpVersion.java:62)
at org.elasticsearch.common.netty.handler.codec.http.HttpRequestDecoder.createMessage(HttpRequestDecoder.java:75)
at org.elasticsearch.common.netty.handler.codec.http.HttpMessageDecoder.decode(HttpMessageDecoder.java:189)
at org.elasticsearch.common.netty.handler.codec.http.HttpMessageDecoder.decode(HttpMessageDecoder.java:101)
at org.elasticsearch.common.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:500)
at org.elasticsearch.common.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(OpenChannelsHandler.java:74)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:268)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:255)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
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:744)
感谢大家的帮助
当我得到这个错误时,我将端口从9200更改为9300。希望它对你有用。
注意:我是elasticsearch的初学者。
可能这不会解决你的问题,但它可能会帮助其他乞丐搜索相同的错误信息,并被引导到这个页面。
您配置elasticsearch(仅使用集群名称)的方式触发集群的多播发现。您可以尝试直接在集群中配置,看看是否有效:
elasticsearch {
host=>"ip_here"
port=>9200
protocol=>http
}
同时你的集群输出显示你的集群处于"黄色"状态,所以你可能想弄清楚那里发生了什么——你希望它是"绿色"。
我所犯的错误是在配置用于单播发现的Elastic实例时。我无意中将端口号9200添加到单播主机列表的配置中。
不正确:
discovery.zen.ping.multicast.enabled: false
discovery.zen.ping.unicast.hosts: ["localhost.localdomain:9200"]
正确的:
discovery.zen.ping.multicast.enabled: false
discovery.zen.ping.unicast.hosts: ["localhost.localdomain"]
将端口更改为9300就可以了。但最好还是看看弹性搜索服务。这可以归结为。索引不会发生,因此出现了这个例外。我也是ELK堆栈的初学者。
如果您不想更改端口,那么登录到每个elasticsearch节点并运行/etc/init.d/elasticsearch开始