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(ClusterClient.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/
