flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Zeppelin Integration
Date Wed, 21 Oct 2015 16:57:26 GMT
Hi Trevor,

in order to use Zeppelin with a different Flink version in local mode,
meaning that Zeppelin starts a LocalFlinkMiniCluster when executing your
jobs, you have to build Zeppelin and change the flink.version property in
the zeppelin/flink/pom.xml file to the version you want to use.

If you want to let Zeppelin submit jobs to a remote cluster, you should
build Zeppelin with the version of your cluster. That’s because internally
Zeppelin will use this version to construct a JobGraph which is then
submitted to the cluster. In order to configure the remote cluster, you
have to go the *Interpreter* page and scroll down to the *flink* section.
There you have to specify the address of your cluster under *host* and the
port under *port*. This should then be used to submit jobs to the Flink

I hope this answers your question.

Btw: If you want to use Zeppelin with the latest Flink 0.10-SNAPSHOT
version, you should checkout my branch
where I’ve made the necessary changes.


On Wed, Oct 21, 2015 at 5:00 PM, Trevor Grant <trevor.d.grant@gmail.com>

> I'm setting up some Flink/Spark/Zeppelin at work.  Spark+Zeppelin seems to
> be relatively well supported and configurable but the Flink is not so much.
> I want Zeppelin to run against my 0.10 build instead of the 0.6 build that
> ships with Zeppelin.  My best guess at the moment on how to accomplish this
> is to create a symbolic link from the /opt/zepplin/flink folder to
> /opt/flink-0.10, but this feels dirty and wrong.
> Does anyone out there have any experience connecting Zeppelin to a
> non-prepackaged Flink build?
> I feel like there is a great opporutnity for a HOWTO write up if non
> currently exists.
> I'm asking on the Zeppelin user mailing list too as soon as I am added.
> Thanks for any help
> tg
> Trevor Grant
> Data Scientist
> https://github.com/rawkintrevo
> http://stackexchange.com/users/3002022/rawkintrevo
> *"Fortunate is he, who is able to know the causes of things."  -Virgil*

View raw message