Hi Joseph Would you like to give more details about the error message? Best, Guowei
On Thu, Nov 25, 2021 at 2:59 AM Joseph Lorenzini <jlorenz...@gohealth.com> wrote: > Hi all, > > > > I have an implementation of KafkaDeserializationSchema interface that > deserializes a kafka consumer record into a generic record. > > > > Per the docs, you need to specify the produced type to be > GenericRecordAvroTypeInfo. > > > > > https://flink.apache.org/news/2020/04/15/flink-serialization-tuning-vol-1.html > > > > In the getProducedType method, I return an instance of > GenericRecordAvroTypeInfo with an appropriate schema. This works as > expected. > > > > However, when I wrap this in a tuple, I get a deserialization error. Is > this user error on my part or is this not support? > > > > public TypeInformation<Tuple2<GenericRecord, GenericRecord>> > getProducedType() { > > GenericRecordAvroTypeInfo deserializerType = new > GenericRecordAvroTypeInfo(deserializerSchema); > > GenericRecordAvroTypeInfo errType = new > GenericRecordAvroTypeInfo(GenericRecordDeserializerErrorBuilder.getSchema()); > > return new TupleTypeInfo<>(deserializerType, errType); > > } > > > > > > Thanks, > > Joe > Privileged/Confidential Information may be contained in this message. If > you are not the addressee indicated in this message (or responsible for > delivery of the message to such person), you may not copy or deliver this > message to anyone. In such case, you should destroy this message and kindly > notify the sender by reply email. Please advise immediately if you or your > employer does not consent to Internet email for messages of this kind. > Opinions, conclusions and other information in this message that do not > relate to the official business of my firm shall be understood as neither > given nor endorsed by it. >
