Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jens Grassel
Hi, we've tried to connect to a flink (1.1.3) cluster (started with `start-cluster.sh`) from zeppelin 0.7.3 (bin-all). The cluster is running at localhost:6123 and we configured the interpreter using: [X] Connect to existing process Host : localhost Port : 6123 But if we try to run flink code fr

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jeff Zhang
There's another log file which is interpreter log under the logs folder, could you check that file ? Jens Grassel 于2017年11月8日周三 下午9:01写道: > Hi, > > we've tried to connect to a flink (1.1.3) cluster (started with > `start-cluster.sh`) from zeppelin 0.7.3 (bin-all). > The cluster is running at loc

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jens Grassel
Hi, On Wed, 08 Nov 2017 13:23:11 + Jeff Zhang wrote: JZ> There's another log file which is interpreter log under the logs JZ> folder, could you check that file ? there are just two logfiles in that folder: zeppelin-whatever.log zeppelin-whatever.out However if we configure the interpreter

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jeff Zhang
zeppelin-interpreter-flink-whatever.log is what I mean Jens Grassel 于2017年11月8日周三 下午9:42写道: > Hi, > > On Wed, 08 Nov 2017 13:23:11 + > Jeff Zhang wrote: > > JZ> There's another log file which is interpreter log under the logs > JZ> folder, could you check that file ? > > there are just two

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jens Grassel
On Wed, 08 Nov 2017 13:52:50 + Jeff Zhang wrote: JZ> zeppelin-interpreter-flink-whatever.log is what I mean As mentioned this log file is only created by the embedded flink interpreter. If the "Connect to existing process" option is used the file is not created and even if it exist no data

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jeff Zhang
I think you misunderstand the connecting existing process, it means connecting to an existing zeppelin interpreter process. Here it is flink interpreter process. But seems you are configure it to connect to flink cluster. I am not expert in flink, for how to connect to flink cluster, someone else m

Error Role to group Mapping - Zeppeling Shiro.ini

2017-11-08 Thread Carlos Andres Zambrano Barrera
Hi Everyone! We are working in zeppelin 0.7.0 and currently we have the following configuration in shiro.ini 1. ldapRealm.contextFactory.systemUsername=DC=ad,DC=something,DC=com 2. #ldapRealm.contextFactory.systemPassword=SomePassw0rd 3. ldapRealm.contextFactory.authenticationMechanism=

Re: Cannot connect to Flink cluster (TTransportException)

2017-11-08 Thread Jens Grassel
Hi, On Wed, 08 Nov 2017 14:47:00 + Jeff Zhang wrote: JZ> I think you misunderstand the connecting existing process, it means JZ> connecting to an existing zeppelin interpreter process. Here it is JZ> flink interpreter process. But seems JZ> you are configure it to connect to flink cluster. I