Re: Cannot pass objects with null-valued fields to the next operator

Hi Stephan, In the end I decided to specify a default value (e.g. empty string) when a field is null. On Mon, Aug 29, 2016 at 11:25 AM, Stephan Ewen wrote: > Hi! > > Null is indeed not supported for some basic data types (tuples / case > classes). > > Can you use Option for nullable fields? > >

Re: Cannot pass objects with null-valued fields to the next operator

Hi! Null is indeed not supported for some basic data types (tuples / case classes). Can you use Option for nullable fields? Stephan On Mon, Aug 29, 2016 at 8:04 PM, Jack Huang wrote: > Hi all, > > It seems like flink does not allow passing case class objects with > null-valued fields to the

Cannot pass objects with null-valued fields to the next operator

Hi all, It seems like flink does not allow passing case class objects with null-valued fields to the next operators. I am getting the following error message: *Caused by: java.lang.RuntimeException: Could not forward element to next operator* at org.apache.flink.streaming.runtime.task