I'm trying to catch exception throws by the kafka source, and I've got the answer that exception in source or sink cannot be caught.
Thanks Haibo Sun <sunhaib...@163.com> 于2019年7月8日周一 下午3:54写道： > Hi, Zhechao > > Usually, if you can, share your full exception stack and where you are > trying to capture exceptions in your code (preferably with posting your > relevant code directly > ). That will help us understand and locate the issue you encounter. > > Best, > Haibo > > At 2019-07-08 14:11:22, "Zhechao Ma" <mazhechaomaill...@gmail.com> wrote: > > Hello, > > I'm using flinkKafkaConsumer to read message from a kafka topic with > JSONKeyValueDeserializationSchema. When the message is json formatted, > everything works fine, but it throws NullPointerException when processing a > message is not json formatted. I try to catch the exception but cannot do > that. > > Can anyone give out some tips? > > flink: 1.5 > flink-kafka: 1.5 > kafka-clients: 0.10.1.2_2.11 > flink-json: > > -- > Thanks > Zhechao Ma > > -- Thanks Zhechao Ma
