You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Ryan (Jira)" <ji...@apache.org> on 2019/12/30 08:24:00 UTC
[jira] [Updated] (STORM-3561) java.lang.RuntimeException:
java.io.UTFDataFormatException
[ https://issues.apache.org/jira/browse/STORM-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ryan updated STORM-3561:
------------------------
Priority: Blocker (was: Major)
> 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)