{"action":"opened","issue":{"url":"https://api.github.com/repos/elasticsearch/logstash/issues/2330","labels_url":"https://api.github.com/repos/elasticsearch/logstash/issues/2330/labels{/name}","comments_url":"https://api.github.com/repos/elasticsearch/logstash/issues/2330/comments","events_url":"https://api.github.com/repos/elasticsearch/logstash/issues/2330/events","html_url":"https://github.com/elasticsearch/logstash/issues/2330","id":53770597,"number":2330,"title":"java.io.EOFException for logstash-1.4.2 elasticsearch_river output","user":{"login":"zhenghu","id":3342705,"avatar_url":"https://avatars.githubusercontent.com/u/3342705?v=3","gravatar_id":"","url":"https://api.github.com/users/zhenghu","html_url":"https://github.com/zhenghu","followers_url":"https://api.github.com/users/zhenghu/followers","following_url":"https://api.github.com/users/zhenghu/following{/other_user}","gists_url":"https://api.github.com/users/zhenghu/gists{/gist_id}","starred_url":"https://api.github.com/users/zhenghu/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/zhenghu/subscriptions","organizations_url":"https://api.github.com/users/zhenghu/orgs","repos_url":"https://api.github.com/users/zhenghu/repos","events_url":"https://api.github.com/users/zhenghu/events{/privacy}","received_events_url":"https://api.github.com/users/zhenghu/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2015-01-08T16:35:25Z","updated_at":"2015-01-08T16:35:25Z","closed_at":null,"body":"I got EOFException when I use elasticsearch_river as output.\r\n\r\nHere is my config file : \r\n  ```\r\n  input {\r\n        file {\r\n                path => \"/tmp/logstash/logstash-1.4.2/log.txt\"\r\n        }\r\n }\r\n\r\n filter {\r\n }\r\n\r\n output {\r\n         elasticsearch_river {\r\n                rabbitmq_host => \"hostname\"\r\n                rabbitmq_port => 15671\r\n                es_host => \"hostname\"\r\n                user => \"user\"\r\n                password => \"password\"\r\n        }\r\n }\r\n ```\r\n\r\n This is the stack trace : \r\n ```\r\nException in thread \">output\" java.io.IOException\r\n        at com.rabbitmq.client.impl.AMQChannel.wrap(com/rabbitmq/client/impl/AMQChannel.java:106)\r\n        at com.rabbitmq.client.impl.AMQChannel.wrap(com/rabbitmq/client/impl/AMQChannel.java:102)\r\n        at com.rabbitmq.client.impl.AMQConnection.start(com/rabbitmq/client/impl/AMQConnection.java:378)\r\n        at com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:516)\r\n        at com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:533)\r\n        at java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:606)\r\n        at RUBY.new_connection_impl(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare/session.rb:387)\r\n        at org.jruby.RubyProc.call(org/jruby/RubyProc.java:271)\r\n        at RUBY.converting_rjc_exceptions_to_ruby(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare/session.rb:357)\r\n        at RUBY.new_connection_impl(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare/session.rb:382)\r\n        at RUBY.initialize(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare/session.rb:82)\r\n        at RUBY.connect(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare/session.rb:69)\r\n        at RUBY.connect(/tmp/logstash/logstash-1.4.2/vendor/bundle/jruby/1.9/gems/march_hare-2.1.2-java/lib/march_hare.rb:20)\r\n        at RUBY.connect(/tmp/logstash/logstash-1.4.2/lib/logstash/outputs/rabbitmq/march_hare.rb:111)\r\n        at RUBY.register(/tmp/logstash/logstash-1.4.2/lib/logstash/outputs/rabbitmq/march_hare.rb:18)\r\n        at RUBY.prepare_river(/tmp/logstash/logstash-1.4.2/lib/logstash/outputs/elasticsearch_river.rb:111)\r\n        at RUBY.register(/tmp/logstash/logstash-1.4.2/lib/logstash/outputs/elasticsearch_river.rb:89)\r\n        at org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)\r\n        at RUBY.outputworker(/tmp/logstash/logstash-1.4.2/lib/logstash/pipeline.rb:220)\r\n        at RUBY.start_outputs(/tmp/logstash/logstash-1.4.2/lib/logstash/pipeline.rb:152)\r\n        at java.lang.Thread.run(java/lang/Thread.java:745)\r\nCaused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.io.EOFException\r\n        at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)\r\n        at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)\r\n        at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)\r\n        at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:321)\r\n        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516)\r\n        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)\r\n        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)\r\n        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n        at java.lang.reflect.Method.invoke(Method.java:606)\r\n        at org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(JavaMethod.java:440)\r\n        at org.jruby.javasupport.JavaMethod.invokeDirect(JavaMethod.java:304)\r\n        at org.jruby.java.invokers.InstanceMethodInvoker.call(InstanceMethodInvoker.java:52)\r\n        at org.jruby.internal.runtime.methods.AliasMethod.call(AliasMethod.java:56)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.CallNoArgNode.interpret(CallNoArgNode.java:60)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.IfNode.interpret(IfNode.java:118)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)\r\n        at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)\r\n        at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:194)\r\n        at org.jruby.runtime.Interpreted19Block.call(Interpreted19Block.java:125)\r\n        at org.jruby.runtime.Block.call(Block.java:101)\r\n        at org.jruby.RubyProc.call(RubyProc.java:290)\r\n        at org.jruby.RubyProc.call19(RubyProc.java:271)\r\n        at org.jruby.RubyProc$INVOKER$i$0$0$call19.call(RubyProc$INVOKER$i$0$0$call19.gen)\r\n        at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:202)\r\n        at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:198)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.CallNoArgNode.interpret(CallNoArgNode.java:60)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.RescueNode.executeBody(RescueNode.java:221)\r\n        at org.jruby.ast.RescueNode.interpret(RescueNode.java:116)\r\n        at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:161)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:190)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:316)\r\n        at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:145)\r\n        at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:154)\r\n        at org.jruby.ast.FCallNoArgBlockNode.interpret(FCallNoArgBlockNode.java:32)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:139)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:182)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.CallNoArgNode.interpret(CallNoArgNode.java:60)\r\n        at org.jruby.ast.InstAsgnNode.interpret(InstAsgnNode.java:95)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:247)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:222)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:356)\r\n        at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:213)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:217)\r\n        at org.jruby.RubyClass.newInstance(RubyClass.java:811)\r\n        at org.jruby.RubyClass$INVOKER$i$newInstance.call(RubyClass$INVOKER$i$newInstance.gen)\r\n        at org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroOrOneOrTwoOrNBlock.call(JavaMethod.java:314)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:346)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:204)\r\n        at org.jruby.ast.FCallTwoArgNode.interpret(FCallTwoArgNode.java:38)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:182)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:198)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:326)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:170)\r\n        at org.jruby.ast.CallSpecialArgNode.interpret(CallSpecialArgNode.java:67)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:182)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:198)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:326)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:170)\r\n        at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)\r\n        at org.jruby.ast.InstAsgnNode.interpret(InstAsgnNode.java:95)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.ast.RescueNode.executeBody(RescueNode.java:221)\r\n        at org.jruby.ast.RescueNode.interpret(RescueNode.java:116)\r\n        at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:139)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:182)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.VCallNode.interpret(VCallNode.java:88)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:139)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:182)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.CallNoArgNode.interpret(CallNoArgNode.java:60)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:139)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:182)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.VCallNode.interpret(VCallNode.java:88)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:112)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:164)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:286)\r\n        at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:81)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:85)\r\n        at org.jruby.RubySymbol$1.yieldInner(RubySymbol.java:445)\r\n        at org.jruby.RubySymbol$1.yield(RubySymbol.java:465)\r\n        at org.jruby.runtime.Block.yield(Block.java:142)\r\n        at org.jruby.RubyArray.eachCommon(RubyArray.java:1606)\r\n        at org.jruby.RubyArray.each(RubyArray.java:1613)\r\n        at org.jruby.RubyArray$INVOKER$i$0$0$each.call(RubyArray$INVOKER$i$0$0$each.gen)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:316)\r\n        at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:145)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:149)\r\n        at org.jruby.ast.CallNoArgBlockPassNode.interpret(CallNoArgBlockPassNode.java:53)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)\r\n        at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:139)\r\n        at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:182)\r\n        at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:306)\r\n        at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:136)\r\n        at org.jruby.ast.VCallNode.interpret(VCallNode.java:88)\r\n        at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)\r\n        at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)\r\n        at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)\r\n        at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:194)\r\n        at org.jruby.runtime.Interpreted19Block.call(Interpreted19Block.java:125)\r\n        at org.jruby.runtime.Block.call(Block.java:101)\r\n        at org.jruby.RubyProc.call(RubyProc.java:290)\r\n        at org.jruby.RubyProc.call(RubyProc.java:228)\r\n        at org.jruby.internal.runtime.RubyRunnable.run(RubyRunnable.java:99)\r\n        at java.lang.Thread.run(Thread.java:745)\r\nCaused by: java.io.EOFException\r\n        at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:290)\r\n        at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)\r\n        at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:131)\r\n        at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:533)\r\n ```"}}