Uploaded image for project: 'Eagle'
  1. Eagle
  2. EAGLE-1091

serialize exception while processing field which length more than 64k

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: v0.5.0, v0.5.1
    • Fix Version/s: None
    • Component/s: Core::Alert Engine
    • Labels:
      None

      Description

      java.lang.AssertionError: java.io.UTFDataFormatException: encoded string too long: 228413 bytes
      at com.google.common.io.ByteStreams$ByteArrayDataOutputStream.writeUTF(ByteStreams.java:530) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.serialization.impl.StringSerializer.serialize(StringSerializer.java:28) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.serialization.impl.StringSerializer.serialize(StringSerializer.java:25) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.serialization.impl.StreamEventSerializer.serialize(StreamEventSerializer.java:79) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.serialization.impl.PartitionedEventSerializerImpl.serialize(PartitionedEventSerializerImpl.java:74) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.serialization.impl.PartitionedEventSerializerImpl.serialize(PartitionedEventSerializerImpl.java:81) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.spout.SpoutOutputCollectorWrapper.emit(SpoutOutputCollectorWrapper.java:156) ~[stormjar.jar:?]
      at org.apache.storm.kafka.PartitionManager.next(PartitionManager.java:160) ~[stormjar.jar:?]
      at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:135) ~[stormjar.jar:?]
      at org.apache.eagle.alert.engine.spout.CorrelationSpout.nextTuple(CorrelationSpout.java:174) ~[stormjar.jar:?]
      at org.apache.storm.daemon.executor$fn_6505$fn6520$fn_6551.invoke(executor.clj:651) ~[storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
      at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484) [storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
      at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
      at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
      Caused by: java.io.UTFDataFormatException: encoded string too long: 228413 bytes
      at java.io.DataOutputStream.writeUTF(DataOutputStream.java:364) ~[?:1.8.0_131]
      at java.io.DataOutputStream.writeUTF(DataOutputStream.java:323) ~[?:1.8.0_131]
      at com.google.common.io.ByteStreams$ByteArrayDataOutputStream.writeUTF(ByteStreams.java:528) ~[stormjar.jar:?]
      ... 13 more

        Attachments

          Activity

            People

            • Assignee:
              yonzhang2012 Edward Zhang
              Reporter:
              fanfan zhiwen wang
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: