I'm not sure but you need to upgrade the version of Flink and build it up again.
On Sun, Jul 2, 2017 at 6:25 PM, Günter Hipler <guenter.hip...@unibas.ch> wrote: > Hi, > > I tried to establish a connection from Zeppelin to the latest Flink > version (1.3.1) > > Using the latest flink version I got > > text: org.apache.flink.api.scala.DataSet[String] = > org.apache.flink.api.scala.DataSet@69b8836f > counts: org.apache.flink.api.scala.AggregateDataSet[(String, Int)] = > org.apache.flink.api.scala.AggregateDataSet@5a46c8ba > org.apache.flink.client.program.ProgramInvocationException: The program > execution failed: Communication with JobManager failed: Lost connection to > the JobManager. > at org.apache.flink.client.program.ClusterClient.run(ClusterCli > ent.java:409) > > The same test job against the Flink 1.1.3 cluster is possible. (1.1.3 is > actually part of the current Zeppelin distribution 0.7.2 and upcoming 0.8 > as Interpreter) > > Is there anybody who has experiences in trying to update the Zeppelin > interpreter? > > Thanks a lot! > > Günter > > > -- > Universität Basel > Universitätsbibliothek > Günter Hipler > Projekt SwissBib > Schoenbeinstrasse 18-20 > 4056 Basel, Schweiz > Tel.: + 41 (0)61 267 31 12 Fax: ++41 61 267 3103 > E-Mail guenter.hip...@unibas.ch > URL: www.swissbib.org / http://www.ub.unibas.ch/ > > -- 이종열, Jongyoul Lee, 李宗烈 http://madeng.net
