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. >> >
