Manage Flink job third party libraries with Zeppelin on a Flink cluster

[Spico Florin <sp...@gmail.com>]

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