The error message is: org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Communication with JobManager failed: Lost connection to the JobManager.
Am 09.04.2018 um 14:12 schrieb kedar mhaswade: > 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 > <mailto: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 <mailto: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 <mailto: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. >> >> >
