Ryan created STORM-3561:
---------------------------
Summary: 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
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)
