Hi, We have seen something similar in Flink 1.2. We have an operation that parses some JSON, and when it fails to parse it, we can see the ClassNotFoundException for the relevant exception (in our case JsResultException from the play-json library). The library is indeed in the shaded JAR, otherwise we would not be able to parse the JSON.
Cheers, Bruno On Wed, 8 Mar 2017 at 12:57 Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > Hi Shannon, > > Just to clarify: > > From the error trace, it seems like that the messages fetched from Kafka > are serialized `AmazonS3Exception`s, and you’re emitting a stream of > `AmazonS3Exception` as records from FlinkKafkaConsumer? > Is this correct? If so, I think we should just make sure that the > `com.amazonaws.services.s3.model.AmazonS3Exception` class exists in the > user fat jar. > > Also, what is the Flink version you are using? > > Cheers, > Gordon >
