This has been driving me crazy ;). I installed elasticsearch 0.20.1, it
starts up fine (via /etc/init.d/elasticsearch, this is a debian box). The
log is quiet up to the moment I start logstash (1.1.5). All I want is to
run logstash/elasticsearch/kibana on my centralized rsyslog setup. I get
the exceptions below as soon as I start logstash....
Any help appreciated!
Thanks!
OD
root@cmd-center:~# less /var/log/elasticsearch/enthought-es.log
[2012-12-13 16:50:48,370][WARN ][bootstrap ] jvm uses the
client vm, make sure to run java with the server vm for best performance
by adding -server to the command line
[2012-12-13 16:50:48,380][INFO ][node ] [command
center] {0.20.1}[5361]: initializing ...
[2012-12-13 16:50:48,389][INFO ][plugins ] [command
center] loaded [], sites []
[2012-12-13 16:50:51,732][INFO ][node ] [command
center] {0.20.1}[5361]: initialized
[2012-12-13 16:50:51,732][INFO ][node ] [command
center] {0.20.1}[5361]: starting ...
[2012-12-13 16:50:51,860][INFO ][transport ] [command
center] bound_address {inet[/0:0:0:0:0:0:0:0:9300]}, publish_address
{inet[/10.6.0.88:9300]}
[2012-12-13 16:50:54,895][INFO ][cluster.service ] [command
center] new_master [command
center][OnUSxbKiTKKkaU70ODlapw][inet[/10.6.0.88:9300]]{master=true},
reason: zen-disco-join (elected_as_master)
[2012-12-13 16:50:54,948][INFO ][discovery ] [command
center] en-es/OnUSxbKiTKKkaU70ODlapw
[2012-12-13 16:50:55,139][INFO ][http ] [command
center] bound_address {inet[/0:0:0:0:0:0:0:0:9200]}, publish_address
{inet[/10.6.0.88:9200]}
[2012-12-13 16:50:55,139][INFO ][node ] [command
center] {0.20.1}[5361]: started
[2012-12-13 16:50:55,280][INFO ][gateway ] [command
center] recovered [0] indices into cluster_state
[2012-12-13 16:53:36,293][WARN ][transport.netty ] [command
center] exception caught on transport layer [[id: 0x271f434f,
/10.6.0.88:54803 => /10.6.0.88:9300]], closing connection
java.io.StreamCorruptedException: invalid internal transport message format
at
org.elasticsearch.transport.netty.SizeHeaderFrameDecoder.decode(SizeHeaderFrameDecoder.java:27)
at
org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:422)
at
org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)
at
org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at
org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:558)
at
org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:786)
at
org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(OpenChannelsHandler.java:74)
at
org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:558)
at
org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:553)
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:84)
at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.processSelectedKeys(AbstractNioWorker.java:471)
at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:332)
--