Hi! There are some people familiar with the Zeppelin integration. CCing Till and Trevor. Otherwise, you could also send this to the Zeppelin community.
Cheers, Max On Wed, Aug 24, 2016 at 12:58 PM, Frank Dekervel <ker...@gmail.com> wrote: > Hello, > > for reference: > > i already found out that "connect to existing process" was my error here: it > means connecting to an existing zeppelin interpreter, not an existing flink > cluster. After fixing my error, i'm now in the same situation as described > here: > > https://stackoverflow.com/questions/38688277/flink-zeppelin-not-responding > > i guess it's more a zeppelin problem than a flink problem tho, as i see both > interpreter JVM and main zeppelin JVM waiting on thrift input (so it seems > they are waiting for each other) > > greetings, > Frank > > > > > On Tue, Aug 23, 2016 at 2:09 PM, Frank Dekervel <ker...@gmail.com> wrote: >> >> Hello, >> >> I try to set up apache zeppelin with a flink cluster (one jobmanager, one >> task manager). >> >> What i did was using the dockerfiles in flink-contrib/docker-flink + the >> latest binary release of apache zeppelin with all interpreters: >> >> >> https://github.com/apache/flink/blob/master/flink-contrib/docker-flink/Dockerfile >> (i changed the flink version to 1.0.3 to match zeppelin's flink version) >> >> I built another docker image around the latest binary release of zeppelin >> (with all interpreters), and i reconfigure the flink interpreter: >> >> connect to existing process >> host: jobmanager, port: 6123 >> i removed all other properties >> >> when i try to submit a flink job, i get an error state and the following >> exception appears in the log (nothing appears in the jobmanager log) >> >> ERROR [2016-08-23 11:44:57,932] ({Thread-16} >> JobProgressPoller.java[run]:54) - Can not get or update progress >> org.apache.zeppelin.interpreter.InterpreterException: >> org.apache.thrift.transport.TTransportException >> at >> org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getProgress(RemoteInterpreter.java:373) >> at >> org.apache.zeppelin.interpreter.LazyOpenInterpreter.getProgress(LazyOpenInterpreter.java:111) >> at >> org.apache.zeppelin.notebook.Paragraph.progress(Paragraph.java:237) >> at >> org.apache.zeppelin.scheduler.JobProgressPoller.run(JobProgressPoller.java:51) >> Caused by: org.apache.thrift.transport.TTransportException >> at >> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) >> at >> org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) >> at >> org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) >> at >> org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.recv_getProgress(RemoteInterpreterService.java:296) >> at >> org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.getProgress(RemoteInterpreterService.java:281) >> at >> org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getProgress(RemoteInterpreter.java:370) >> ... 3 more >> >> Flink in local mode works fine on zeppelin. >> Could somebody point me to what i'm doing wrong ? >> >> Thanks a lot! >> Frank >> >> >> >
