Great to hear. Yes, if you can help fix this issue that would be great.
Cheers,
Till
On Tue, Mar 9, 2021 at 3:41 PM Bobby Richard
wrote:
> Great thanks, I was able to work around the issue by implementing my own
> KafkaRecordDeserializer. I will take a stab at a PR to fix the bug, should
> be a
Great thanks, I was able to work around the issue by implementing my own
KafkaRecordDeserializer. I will take a stab at a PR to fix the bug, should
be an easy fix.
On Tue, Mar 9, 2021 at 9:26 AM Till Rohrmann wrote:
> Hi Bobby,
>
> This is most likely a bug in Flink. Thanks a lot for reporting t
Hi Bobby,
This is most likely a bug in Flink. Thanks a lot for reporting the issue
and analyzing it. I have created an issue for tracking it [1].
cc Becket.
[1] https://issues.apache.org/jira/browse/FLINK-21691
Cheers,
Till
On Mon, Mar 8, 2021 at 3:35 PM Bobby Richard
wrote:
> I'm receiving
I'm receiving the following exception when trying to use a KafkaSource from
the new DataSource API.
Exception in thread "main" java.lang.NullPointerException
at
org.apache.flink.connector.kafka.source.reader.deserializer.ValueDeserializerWrapper.getProducedType(ValueDeserializerWrapper.java:79)
at
