heyu dou created FLINK-24606: -------------------------------- Summary: AvroDeserializationSchema buffer is not clean Key: FLINK-24606 URL: https://issues.apache.org/jira/browse/FLINK-24606 Project: Flink Issue Type: Bug Components: API / DataStream Reporter: heyu dou
org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse org.apache.avro.io.BinaryDecoder. But the way it is used is wrong. Should be reset Decoder before deserialization(). -- This message was sent by Atlassian Jira (v8.3.4#803005)