[
https://issues.apache.org/jira/browse/STORM-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072896#comment-17072896
]
Simon Cooper commented on STORM-3561:
-------------------------------------
Could be related to ARIC-3582, could be caused by data corruption between
workers?
> java.lang.RuntimeException: java.io.UTFDataFormatException
> ----------------------------------------------------------
>
> Key: STORM-3561
> URL: https://issues.apache.org/jira/browse/STORM-3561
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-client
> Affects Versions: 2.1.0
> Reporter: Ryan
> Priority: Blocker
>
> My application encountered the following problems online, which caused my
> worker to exit unexpectedly. Does anyone know why this is? I am considering
> whether to use the java native serialization instead of Kryo
>
> 2019-12-29 21:35:41.669 o.a.s.m.n.StormServerHandler
> Netty-server-localhost-1800-worker-1 [ERROR] server errors in handling the
> request
> java.lang.RuntimeException: java.io.eTFDataFormatException
> at
> org.apache.storm.serialization.SerializableSerializer.read(SerializableSerializer.java:53)
> ~[storm-client-2.1.0.jar:2.1.0]
> at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:793)
> ~[kryo-3.0.3.jar:?]
> at
> com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:134)
> ~[kryo-3.0.3.jar:?]
> at
> com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:40)
> ~[kryo-3.0.3.jar:?]
> at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:689)
> ~[kryo-3.0.3.jar:?]
> at
> org.apache.storm.serialization.KryoValuesDeserializer.deserializeFrom(KryoValuesDeserializer.java:31)
> ~[storm-client-2.1.0.jar:2.1.0]
> at
> org.apache.storm.serialization.KryoTupleDeserializer.deserialize(KryoTupleDeserializer.java:45)
> ~[storm-client-2.1.0.jar:2.1.0]
> at
> org.apache.storm.messaging.DeserializingConnectionCallback.recv(DeserializingConnectionCallback.java:66)
> ~[storm-client-2.1.0.jar:2.1.0]
> at org.apache.storm.messaging.netty.Server.enqueue(Server.java:146)
> ~[storm-client-2.1.0.jar:2.1.0]
> at org.apache.storm.messaging.netty.Server.received(Server.java:264)
> ~[storm-client-2.1.0.jar:2.1.0]
> at
> org.apache.storm.messaging.netty.StormServerHandler.channelRead(StormServerHandler.java:51)
> ~[storm-client-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:426)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at
> org.apache.storm.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
> [storm-shaded-deps-2.1.0.jar:2.1.0]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
> Caused by: java.io.UTFDataFormatException
> at
> java.io.ObjectInputStream$BlockDataInputStream.readUTFSpan(ObjectInputStream.java:3470)
> ~[?:1.8.0_231]
> at
> java.io.ObjectInputStream$BlockDataInputStream.readUTFBody(ObjectInputStream.java:3414)
> ~[?:1.8.0_231]
> at
> java.io.ObjectInputStream$BlockDataInputStream.readUTF(ObjectInputStream.java:3226)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readUTF(ObjectInputStream.java:1133)
> ~[?:1.8.0_231]
> at java.io.ObjectStreamClass.readNonProxy(ObjectStreamClass.java:768)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readClassDescriptor(ObjectInputStream.java:891)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1857)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
> ~[?:1.8.0_231]
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
> ~[?:1.8.0_231]
> at
> org.apache.storm.serialization.SerializableSerializer.read(SerializableSerializer.java:51)
> ~[storm-client-2.1.0.jar:2.1.0]
> ... 31 more
> 2019-12-29 21:35:41.673 o.a.s.m.n.StormServerHandler
> Netty-server-localhost-1800-worker-1 [INFO] Received error in netty thread..
> terminating server...
> 2019-12-29 21:35:41.674 o.a.s.d.w.Worker Thread-43 [INFO] Shutting down
> worker owl_analyze_1228_0-16-1577543204
> f611fb0f-3a97-4043-bb42-8f74190926ff-10.16.20.6 1800
> 2019-12-29 21:35:41.675 o.a.s.u.Utils Thread-42 [INFO] Halting after 3 seconds
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
