flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: FlinkKinesisConsumer throws "Unknown datum type org.joda.time.DateTime"
Date Thu, 20 Feb 2020 15:30:35 GMT
What you could try is bumping the avro dependency to 1.9.2 . I don't 
whether this will /just work/, but it's worth a shot.

On 20/02/2020 16:25, Lian Jiang wrote:
> Thanks. I see from mvnrepository that even Flink-Avro 1.10 (the latest) uses avro 1.8.2.
Does this mean I have to use GenericData instead of avro POJOs if I use FlinkKinesisConsumer?
>
> Sent from my iPhone
>
>> On Feb 20, 2020, at 4:34 AM, Chesnay Schepler <chesnay@apache.org> wrote:
>>


Mime
View raw message