IllegalArgumentException: invalid version format

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

What versions of Elasticsearch and Logstash are you using?

elasticsearch-1.6.0,logstash-1.5.2

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.

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)

Hi, bro.Do you fixed this issue?