Hmm. What error do you see on the Zeppelin console when you click the run (flink code) button after making these changes for flink interpreter config (I assume you restart the interpreter)?
Regards, Kedar On Mon, Apr 9, 2018 at 12:50 AM, Rico Bergmann <i...@ricobergmann.de> wrote: > Hi. > > Thanks for your reply. But this also didn’t work for me. > > In the JM log I get an akka Error („dropping message for non-local > recipient“). > > My setup: I have Flink running on Kubernetes cluster, version 1.4.2. > zeppelin is version 0.8 using the flink interpreter compiled against flink > 1.1.3. > When submitting a job with the CLI tool everything is working fine. The > CLI tool is version 1.4.2 ... > > Any other suggestions? > > Thanks a lot. > Best, > Rico. > > > Am 06.04.2018 um 18:44 schrieb kedar mhaswade <kedar.mhasw...@gmail.com>: > > Yes. You need to add the two properties for the job manager (I agree, it > is confusing because the properties named "host" and "port" already > available, but the names of the useful properties are different): > > Could you please try this and let us know if it works for you? > > Regards, > Kedar > > > On Fri, Apr 6, 2018 at 5:51 AM, Dipl.-Inf. Rico Bergmann < > i...@ricobergmann.de> wrote: > >> Hi! >> >> Has someone successfully integrated Flink 1.4.2 into Zeppelin notebook >> (using Flink in cluster mode, not local mode)? >> >> Best, >> >> Rico. >> >> >
