Skip to content

EventProcessFunction throws NPE if user func returns None

Gmodena requested to merge T335706-handle-none-events into main

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).

Merge request reports