Throw TransportSerializationException when jdk 1.6.0_22 client connected jdk 1.7.0_45 Es server

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Throw TransportSerializationException when jdk 1.6.0_22 client connected jdk 1.7.0_45 Es server

liangwb2001
Hi:
    I setup a elasticsearch cluster with jdk 1.7.0_45, and config action.auto_create_index: false.
        When I used jdk 1.6.0_22 client connect the cluter, and update a document to a not existing index, it throwed TransportSerializationException:
org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
        at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
        at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:123)
        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:108)
        at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
        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$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
Caused by: java.io.StreamCorruptedException: unexpected end of block data
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
        at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
        at java.io.ObjectInputStream.defaultReadObject(ObjectInputStream.java:479)
        at java.net.InetSocketAddress.readObject(InetSocketAddress.java:169)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
        at java.lang.reflect.Method.invoke(Method.java:597)
        at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:974)
        at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1848)
        at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
        at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
        at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
        at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
        at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
        at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
        at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
        at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
        at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:167)
        ... 23 more
       
       
        ElasticServers has no error log.
   It's ok when update to a exist index.
   Or use a jdk 1.7.0_45 client to update a not exist index, it throws right error: index not exist.
   
   Is there something wrong?
Reply | Threaded
Open this post in threaded view
|

Re: Throw TransportSerializationException when jdk 1.6.0_22 client connected jdk 1.7.0_45 Es server

dadoonet
You have to use the same Java version on all nodes/clients.

--
David ;-)
Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs


Le 26 déc. 2013 à 11:20, liangwb2001 <[hidden email]> a écrit :

Hi:
   I setup a elasticsearch cluster with jdk 1.7.0_45, and config
action.auto_create_index: false.
   When I used jdk 1.6.0_22 client connect the cluter, and update a document
to a not existing index, it throwed TransportSerializationException:
org.elasticsearch.transport.TransportSerializationException: Failed to
deserialize exception response from stream
   at
org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
   at
org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:123)
   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:108)
   at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
   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$Worker.runTask(ThreadPoolExecutor.java:886)
   at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
   at java.lang.Thread.run(Thread.java:662)
Caused by: java.io.StreamCorruptedException: unexpected end of block data
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.defaultReadObject(ObjectInputStream.java:479)
   at java.net.InetSocketAddress.readObject(InetSocketAddress.java:169)
   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
   at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
   at java.lang.reflect.Method.invoke(Method.java:597)
   at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:974)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1848)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
   at
org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:167)
   ... 23 more
   
   
   ElasticServers has no error log.
  It's ok when update to a exist index.
  Or use a jdk 1.7.0_45 client to update a not exist index, it throws right
error: index not exist.

  Is there something wrong?




--
View this message in context: http://elasticsearch-users.115913.n3.nabble.com/Throw-TransportSerializationException-when-jdk-1-6-0-22-client-connected-jdk-1-7-0-45-Es-server-tp4046685.html
Sent from the ElasticSearch Users mailing list archive at Nabble.com.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/1388053243042-4046685.post%40n3.nabble.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/8DA7FE61-C47D-497B-BA24-0C2ADA468C56%40pilato.fr.
For more options, visit https://groups.google.com/groups/opt_out.
Reply | Threaded
Open this post in threaded view
|

Re: Throw TransportSerializationException when jdk 1.6.0_22 client connected jdk 1.7.0_45 Es server

Ivan Brusic
Oracle made changes to serialization with version 7u21, so it is important not to mix Java versions whose ranges span over that version. I run clients on 6u31 connecting to nodes on 7u4 without issues. 

That said, don't follow my lead and try to stick to the same version consistently. Also note that there are issues at the Lucene level with 7u45, so it might be better to use 7u25.

Cheers,

Ivan


On Fri, Dec 27, 2013 at 12:33 PM, David Pilato <[hidden email]> wrote:
You have to use the same Java version on all nodes/clients.

--
David ;-)
Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs


Le 26 déc. 2013 à 11:20, liangwb2001 <[hidden email]> a écrit :

Hi:
   I setup a elasticsearch cluster with jdk 1.7.0_45, and config
action.auto_create_index: false.
   When I used jdk 1.6.0_22 client connect the cluter, and update a document
to a not existing index, it throwed TransportSerializationException:
org.elasticsearch.transport.TransportSerializationException: Failed to
deserialize exception response from stream
   at
org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
   at
org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:123)
   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:108)
   at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
   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$Worker.runTask(ThreadPoolExecutor.java:886)
   at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
   at java.lang.Thread.run(Thread.java:662)
Caused by: java.io.StreamCorruptedException: unexpected end of block data
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.defaultReadObject(ObjectInputStream.java:479)
   at java.net.InetSocketAddress.readObject(InetSocketAddress.java:169)
   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
   at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
   at java.lang.reflect.Method.invoke(Method.java:597)
   at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:974)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1848)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
   at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
   at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
   at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
   at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
   at
org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:167)
   ... 23 more


   ElasticServers has no error log.
  It's ok when update to a exist index.
  Or use a jdk 1.7.0_45 client to update a not exist index, it throws right
error: index not exist.

  Is there something wrong?




--
View this message in context: http://elasticsearch-users.115913.n3.nabble.com/Throw-TransportSerializationException-when-jdk-1-6-0-22-client-connected-jdk-1-7-0-45-Es-server-tp4046685.html
Sent from the ElasticSearch Users mailing list archive at Nabble.com.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/1388053243042-4046685.post%40n3.nabble.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/8DA7FE61-C47D-497B-BA24-0C2ADA468C56%40pilato.fr.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/CALY%3DcQAHMAat5xwiehaBAqg_-OKWGi3OL_D%2BiBTcdFs4yHOQ6A%40mail.gmail.com.
For more options, visit https://groups.google.com/groups/opt_out.
Reply | Threaded
Open this post in threaded view
|

Re: Throw TransportSerializationException when jdk 1.6.0_22 client connected jdk 1.7.0_45 Es server

liangwb2001
In reply to this post by liangwb2001
Thanks for dadoonet and Ivan's sharing.