[ https://issues.apache.org/jira/browse/STORM-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Richard Zowalla closed STORM-3561. ---------------------------------- Resolution: Won't Fix We are now using Kyro 5 in Storm 2.6.0 - this issue is most likely outdated. If it still happens with Storm 2.6.0, feel free to re-open > 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.20.10#820010)