I removed that line from the code and it seems to have solved the problem.
Thank you very much! :)
All the best,
Laszlo
On Tue, Aug 17, 2021 at 9:54 AM László Ciople
wrote:
> Ok, thank you for the tips. I will modify it and get back to you :)
>
> On Tue, Aug 17, 2021 at 9:42 AM David Morávek wr
Ok, thank you for the tips. I will modify it and get back to you :)
On Tue, Aug 17, 2021 at 9:42 AM David Morávek wrote:
> Hi Laszlo,
>
> Please use reply-all for mailing list replies. This may help others
> finding their answer in the future ;)
>
>
>> sb.append(DeviceDetail.class.getName()).app
Hi Laszlo,
Please use reply-all for mailing list replies. This may help others finding
their answer in the future ;)
> sb.append(DeviceDetail.class.getName()).append('@').append(Integer.toHexString(System.identityHashCode(this))).append('[');
This part will again make your key non-deterministi
Ciople
>> wrote:
>>
>>> Hello,
>>> I am trying to write a Flink application which receives data from Kafka,
>>> does processing on keyed windowed streams and sends results on a
>>> different topic.
>>> Shortly after the job is started it fails with
4:00 PM László Ciople
wrote:
> Hello,
> I am trying to write a Flink application which receives data from Kafka,
> does processing on keyed windowed streams and sends results on a
> different topic.
> Shortly after the job is started it fails with a NullPointerException in
> State
Hello,
I am trying to write a Flink application which receives data from Kafka,
does processing on keyed windowed streams and sends results on a
different topic.
Shortly after the job is started it fails with a NullPointerException in
StateTable.put(). I am really confused by this error, because I
