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,
Jin
hi sunfulin,
which flink version are you using ?
best,
godfrey
sunfulin 于2020年1月10日周五 下午1:50写道：
> Hi, I am running a Flink app while reading Kafka records with JSON format.
> And the connect code is like the following:
>
>
> tableEnv.connect(
>
> new Kafka()
>
> .version(ka
