IllegalArgumentException: invalid version format


(Ashok Gandla) #1

Getting elasticsearch log eeroras Caught exception while handling client http traffic, closing connection
java.lang.IllegalArgumentException: invalid version format: while running logstash.conf file.

And getting logstash logs like WARNING: failed to send ping to
org.elasticsearch.transport.ReceiveTimeoutTransportException: []
[internal:discovery/zen/unicast_gte_1_4] request_id [33] timed out after [3751ms]
at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:529)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

Can you please tell what is my mistake


(Joshua Rich) #2

What versions of Elasticsearch and Logstash are you using?


(Ashok Gandla) #3

elasticsearch-1.6.0,logstash-1.5.2


(Joshua Rich) #4

That's weird, those should be compatible. Are you sure all your ES nodes are running 1.6? Can you gist or pastebin the log messages before and after that first log message (like the full exception trace). It's hard to tell from a single isolated log line exactly what's going on here.


(Ashok Gandla) #5

Please findbelow the config files.
Elasticsearch.yml

cluster.name: MYelasticsearch
node.name: "Franz Kafkaooo"
index.number_of_shards: 5
index.number_of_replicas: 2
network.host: localhost
http.port: 9201

logstash.conf

input {
file {
path => "D:/LOGS/log1.txt"
type => "core2"
start_position => "beginning"
}
}
filter {
csv { columns=> ["TYPE","timestamp","MESSAGE","APPNAME"]
separator => ","
}
}

output {
elasticsearch{
action => "index"
host => "localhost"
index => "logstash-%{+YYYY.MM.dd}"
workers => 1
cluster => "MYelasticsearch"
port => "9201"

}
 stdout {
    codec => rubydebug
}

}

**This is full log of ES.**and it's getting repeated only.
[2015-07-27 13:06:36,049][WARN ][http.netty ] [Franz Kafkaooo] Caught exception while handling client http traffic, closing connection [id: 0xf43c5693, /127
java.lang.IllegalArgumentException: empty text
at org.elasticsearch.common.netty.handler.codec.http.HttpVersion.(HttpVersion.java:89)
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:191)
at org.elasticsearch.common.netty.handler.codec.http.HttpMessageDecoder.decode(HttpMessageDecoder.java:102)
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:337)
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:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)


(senlinwei) #6

Hi, bro.Do you fixed this issue?


(system) #7