Hello, I have a state processor job that at some point tries to read a MapState<String, DTO> in a KeyedStateReaderFunction and, if the map is empty, it doesn't emit anything (it doesn't call the collector). After updating to Flink 2.2.1 I got an NPE in the downstream operator in said job, indicating that a null record was collected somewhere.
It seems to me that the InputFormatSource [1] doesn't check if lastElement is null before collecting. Do you think this could be the reason? [1] https://github.com/apache/flink/blob/release-2.2.1/flink-runtime/src/main/java/org/apache/flink/api/connector/source/lib/InputFormatSource.java#L251-L270 ) Regards, Alexis.
