Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-3561

java.lang.RuntimeException: java.io.UTFDataFormatException

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Won't Fix
    • 2.1.0
    • None
    • storm-client
    • None

    Description

      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

      Attachments

        Activity

          People

            Unassigned Unassigned
            Ryanx Ryan
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: