search

jaegertracing / jaeger-analytics-flink

Big data analytics for Jaeger using Apache Flink
68 stars 23 forks source link

ArrayIndexOutOfBoundsException happened #9

Closed moshuipan closed 4 years ago

moshuipan commented 4 years ago

env: jaeger-collector:v1.12.0 , how could i resolve it? 2019-12-08 12:40:32.624 [Source: KafkaSource -> DeserializeSpan -> FilterLocalSpans (2/4)] INFO org.apache.flink.runtime.taskmanager.Task - Source: KafkaSource -> DeserializeSpan -> FilterLocalSpans (2/4) (9324a78eb55fe4cda7a015c6cc16fabf) switched from RUNNING to FAILED.

java.lang.ArrayIndexOutOfBoundsException: 5
    at org.apache.avro.io.parsing.Symbol$Alternative.getSymbol(Symbol.java:424)
    at org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:290)
    at org.apache.avro.io.parsing.Parser.advance(Parser.java:88)
    at org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:267)
    at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179)
    at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:116)
    at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:222)
    at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:175)
    at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:153)
    at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:145)
moshuipan commented 4 years ago

kafka send a protobuf message to analytics, should i modify SpecificDatumReader to ProtobufDatumReader?

wsx812585705 commented 4 years ago

@moshuipan do you resolve it?