[jira] [Created] (ZEPPELIN-2675) Distributing Jars when using an external flink cluster

["Marco Tagliabue (JIRA)" <ji...@apache.org>]

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)