title: Elastic Search Exception while storing data
body: <p>I'm trying to index a realtime steam using Storm and ElasticSearch and I'm getting this exception. I'm using the following version of ElasticSearch </p>
  
  <pre><code>    &lt;dependency&gt;
          &lt;groupId&gt;org.elasticsearch&lt;/groupId&gt;
          &lt;artifactId&gt;elasticsearch&lt;/artifactId&gt;
          &lt;version&gt;0.90.1&lt;/version&gt;
      &lt;/dependency&gt;
  </code></pre>
  
  <p>Any pointers about where I should start looking ? </p>
  
  <pre><code>org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream
      Caused by: org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
          at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:171)
          at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:125)
          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.channel.Channels.fireMessageReceived(Channels.java:296)
          at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)
          at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)
          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: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:107)
          at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
          at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:88)
          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:722)
      Caused by: java.io.StreamCorruptedException: unexpected end of block data
          at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1370)
          at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1989)
          at java.io.ObjectInputStream.defaultReadObject(ObjectInputStream.java:499)
          at java.lang.Throwable.readObject(Throwable.java:913)
          at sun.reflect.GeneratedMethodAccessor59.invoke(Unknown Source)
          at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
          at java.lang.reflect.Method.invoke(Method.java:601)
          at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1004)
          at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1891)
          at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1796)
          at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1348)
          at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1989)
          at java.io.ObjectInputStream.defaultReadObject(ObjectInputStream.java:499)
          at java.lang.Throwable.readObject(Throwable.java:913)
          at sun.reflect.GeneratedMethodAccessor59.invoke(Unknown Source)
          at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
          at java.lang.reflect.Method.invoke(Method.java:601)
          at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1004)
          at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1891)
          at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1796)
          at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1348)
          at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
          at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
          ... 23 more
  </code></pre>