Re:Re: Null result cannot be used for atomic types

2020-01-12 Thread sunfulin
e. Caused by: java.lang.NullPointerException: Null result cannot be used for atomic types. at DataStreamSinkConversion$5.map(Unknown Source) So the point is how did you write to sink. Can you share these codes? Best, Jingsong Lee On Fri, Jan 10, 2020 at 2:58 PM godfrey he wrote: h

Re: Null result cannot be used for atomic types

2020-01-10 Thread Jingsong Li
Hi sunfulin, Looks like the error is happened in sink instead of source. Caused by: java.lang.NullPointerException: Null result cannot be used for atomic types. at DataStreamSinkConversion$5.map(Unknown Source) So the point is how did you write to sink. Can you share these codes? Best

Re: Null result cannot be used for atomic types

2020-01-09 Thread godfrey he
Types.STRING, Types.STRING) > > ) > > ).withFormat( > > new Json().failOnMissingField(false) > > .deriveSchema() > > ) > > .inAppendMode() > > .registerTableSource(getTableName()); > > > > However, the applica

Null result cannot be used for atomic types

2020-01-09 Thread sunfulin
) ).withFormat( new Json().failOnMissingField(false) .deriveSchema() ) .inAppendMode() .registerTableSource(getTableName()); However, the application throws the following Exception which really confused me. From the code above, the field types are only Types.STRING