Hello! I'm using Zeppelin 0.7.3 with Flink 1.4.2 in cluster mode. My Flink job has dependencies on third party libraries (Flink CEP, jackson json etc) and when I run the notebook, I got ClassNotFoundException on the Flink Task side, even though I have configured the Flink Interpreter dependencies on the mentioned libraries.
This is fine since Flink has dependencies only on the core libraries ( https://ci.apache.org/projects/flink/flink-docs-stable/start/dependencies.html ). Unfortunately, by default Zeppelin Flink Interpreter doesn't pack all the dependencies on the submitted jar file thus we got the exception ClassNotFoundException Therefore, I would like to ask you how can I configure the Flink Interpreter to send to the Flink cluster all the required third party dependencies? Is there any similar environment variable like SPARK_SUBMIT_OPTIONS? I look forward for you answers. Regards, Florin