yufanliu

Thanks for reply. The app is simply consuming a kafka topic with value serialized in avro format. The error is an NPE ``` org.apache.flink.client.program.ProgramInvocationException: The main method caused an error:...

Yes, i'm using the Uber jar and the docker image is flink:1.10.1-scala_2.11