EventProcessFunction throws NPE if user func returns None
Bug: T335706
Currently our API design assumes that a process()
function always emits an output, with record filtering delegated to filter()
(or a custom map()
function).
With this assumption we should treat None
values as an error, and emit them to a side output (e.g. default error handing behavior).