Frank, can you post the zeppelin flink log please?
You can probably find it in zeppelin_dir/logs/*flink*.log You've got a few moving pieces here. I've never run zeppelin against Flink in a docker container. But I think the Zeppelin-Flink log is the first place to look. You say you can't get Zeppelin to work in local mode either right? Just curious, is Zeppelin running in a docker too? Thanks, tg Trevor Grant Data Scientist https://github.com/rawkintrevo http://stackexchange.com/users/3002022/rawkintrevo http://trevorgrant.org *"Fortunate is he, who is able to know the causes of things." -Virgil* On Wed, Aug 24, 2016 at 6:50 AM, Maximilian Michels <m...@apache.org> wrote: > 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 > >> > >> > >> > > >
