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 > > > >