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
