Hi all,
We found the solution:
the problem is Comparator in TreeSet we used as the value of broadcast
state. Kryo is unable to serialize lambda in Comparator, so we changed to
regular class - and everything is fine now.
С уважением,
Василий Мельник
*Glow**Byte Consulting*
Hi all.
In Flink 1.8 we have strange exception that causes job failing:
2019-11-14 15:52:52,071 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph- op4 (1/1)
(797d4c2b85010dab6be5e1d06ff6493a) switched from RUNNING to FAILED.
AsynchronousException{java.lang.Exception: Could not
