Marco Tagliabue created ZEPPELIN-2675:
-----------------------------------------
Summary: Distributing Jars when using an external flink cluster
Key: ZEPPELIN-2675
URL: https://issues.apache.org/jira/browse/ZEPPELIN-2675
Project: Zeppelin
Issue Type: Improvement
Components: Interpreters
Reporter: Marco Tagliabue
In Flink Interpreter when the user loads external dependencies with Web UI,
Interpreter does not distribute jars on worker nodes on Flink external cluster.
The error we get is:
{code:java}
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user
class: org.apache.flink.contrib.streaming.CollectSink
ClassLoader info: URL ClassLoader:
file:
'/tmp/blobStore-611a2404-3baa-4f4b-bd96-dd3200473a50/cache/blob_132dffe4decbd932cb148d54cc2797f84215e6ad'
(valid JAR)
Class not resolvable through given classloader.
{code}
Loading external dependencies only work with MiniCluster and flink version
lower than 1.3.0
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
