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 in
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 wrote:
>
From the stack trace it appears that flink-avro is used, which uses
avro 1.8.2 internally by default,
for which this appears to be a known issue that was fixed in 1.9.?.
Are you sure that avro 1.9.2 is actually being used?
On 19/02/2020 23:53, Lian Jiang wrote:
Hi,
I use a FlinkKinesisConsume
