Re: Flink 1.4.2 in Zeppelin Notebook
FYI: I finally managed to get the new Flink version running in Zeppelin. Besides adding the parameters mentioned below you have to build Zeppelin with profile scala-2.11 and the new Flink version 1.4.2. Best, Rico. Am 09.04.2018 um 14:43 schrieb Rico Bergmann: > > 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. >>> >>> >> >
Re: Flink 1.4.2 in Zeppelin Notebook
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. >> >> >
Re: Flink 1.4.2 in Zeppelin Notebook
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. >> >> >
Re: Flink 1.4.2 in Zeppelin Notebook
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. >> >
Re: Flink 1.4.2 in Zeppelin Notebook
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. > >
Flink 1.4.2 in Zeppelin Notebook
Hi! Has someone successfully integrated Flink 1.4.2 into Zeppelin notebook (using Flink in cluster mode, not local mode)? Best, Rico.
