Hi Henry,
could you share a little reproducible example? From what I see you are
using a custom aggregate function with a case class inside, right?
Flink's case class serializer does not support null because the usage of
`null` is also not very Scala like.
Use a `Row` type for supporting nul
Hi Experts,
In my self-defined UDAF, I found if I return a null value in UDAF,
would cause checkpoint fails, the following is the error log:
I think it is quite a common case to return a null value in UDAF,
because sometimes no value could be determined, why Flink has such a limit
