;>
>>> >>> On 17/09/2020 16:34, Lian Jiang wrote:
>>> >>>
>>> >>> Piotr/Dawid,
>>> >>>
>>> >>> Thanks for the reply. FLINK-18223 seems not to related to this issue
>>>
ass = tClass;
>> >>> this.tSchemaStr = tSchemaStr;
>> >>> this.topic = null;
>> >>> this.schemaRegistryUrl = schemaRegistryUrl;
>> >>> }
>> >>>
>> >>> @Overridepublic T deserialize(C
> >>> SpecificDatumReader reader = new SpecificDatumReader<>(
> >>> generic.getSchema(), tSchema,
> ManagedSpecificData.getForClass(tClass));
> >>> Decoder anotherDecoder =
> DecoderFactory.get().binaryDecoder(avroData, null);
> >>>
t; out.close();
> >>> tSchema = new org.apache.avro.Schema.Parser().parse(tSchemaStr);
> >>> SpecificDatumReader reader = new SpecificDatumReader<>(
> >>> generic.getSchema(), tSchema,
> ManagedSpecificData.getForClass(tClass));
> >>>
tory.fromSpecific() which
creates its private copy of specificData. This private specificData
does not have logical type information. This blocks the deserialized
messages from being passed to downstream operators. Any idea how to
make this work? Appreciated very much!
org.apache.avro.AvroRuntimeException: U
>> ConfluentRegistryDeserializationSchema that comes with
>> Flink or did you
>> built custom DeserializationSchema? Could you maybe share
>> the code for
>> instantiating the source with us? It could help
alizer,
>> this.sourceSettings);
>>
>>
>>
>> Thanks
>>
>> Lian
>>
>>
>>
>>
>> On Thu, Sep 17, 2020 at 2:19 AM Dawid Wysakowicz
>> wrote:
>>
>&g
08:09, Lian Jiang wrote:
>> > Hi,
>> >
>> > i am using avro 1.9.1 + Flink 1.10.1 + Confluent Kafka 5.5. In
>> > Intellij, I can see the FlinkKafkaConsumer already deserialized the
>> > upstream kafka message. However, I got below error
> upstream kafka message. However, I got below error when this message
> > is serialized during pushToOperator. Per the stack trace, the reason
> > is that AvroSerializer is created by AvroFactory.fromSpecific()
> whic
idea how to
> > make this work? Appreciated very much!
> >
> >
> > org.apache.avro.AvroRuntimeException: Unknown datum type
> > java.time.Instant: 2020-09-15T07:00:00Z
> > at
> org.apache.avro.generic.GenericData.getSchemaName(GenericData.java:887)
&
n. This blocks the deserialized
> messages from being passed to downstream operators. Any idea how to
> make this work? Appreciated very much!
>
>
> org.apache.avro.AvroRuntimeException: Unknown datum type
> java.time.Instant: 2020-09-15T07:00:00Z
> at org.apache.avro.ge
is work? Appreciated very much!
>
>
> org.apache.avro.AvroRuntimeException: Unknown datum type
> java.time.Instant: 2020-09-15T07:00:00Z
> at org.apache.avro.generic.GenericData.getSchemaName(GenericData.java:887)
> at
> org.apache.avro.specif
!
org.apache.avro.AvroRuntimeException: Unknown datum type java.time.Instant:
2020-09-15T07:00:00Z
at org.apache.avro.generic.GenericData.getSchemaName(GenericData.java:887)
at
org.apache.avro.specific.SpecificData.getSchemaName(SpecificData.java:420)
at org.apache.avro.generic.GenericData.resolveUnion
13 matches
Mail list logo
