Re: ipython/grpc issues

2018-02-14 Thread Jeff Zhang
BTW, you need to set zeppelin.ipython.grpc.framesize to a large number Ruslan Dautkhanov 于2018年2月15日周四 下午1:16写道: > Thanks a lot for prompt response Jeff. I will give this a try soon. > > > > > -- > Ruslan Dautkhanov > > On Wed, Feb 14, 2018 at 7:31 PM, Jeff Zhang

Re: NullPointerException in paragraph when getting batched TableEnvironment

2018-02-14 Thread Felix Cheung
Does it work within the Flink Scala Shell? From: André Schütz Sent: Wednesday, February 14, 2018 4:02:30 AM To: us...@zeppelin.incubator.apache.org Subject: NullPointerException in paragraph when getting batched TableEnvironment Hi, within the

Re: ipython/grpc issues

2018-02-14 Thread Jeff Zhang
Sorry , miss PR link https://github.com/apache/zeppelin/pull/2802 Jeff Zhang 于2018年2月15日周四 上午10:30写道: > > HI Ruslan, > > Could you help try this PR ? > > > Ruslan Dautkhanov 于2018年2月15日周四 上午1:54写道: > >> I've seen several cases when new ipython interpreter

Re: ipython/grpc issues

2018-02-14 Thread Jeff Zhang
HI Ruslan, Could you help try this PR ? Ruslan Dautkhanov 于2018年2月15日周四 上午1:54写道: > I've seen several cases when new ipython interpreter isn't possible to > stop using "Cancel" > button. > > Interpreter logs shows following errors. > > Then paragraph stops accepting

z.show() compatibility and new UI grid

2018-02-14 Thread Ruslan Dautkhanov
We've noticed two major issues with z.show() after upgrading Zeppelin 1) z.show(df) used to work directly on spark dataframe object, now it produces TypeError: object of type 'DataFrame' has no len() Full exception stack in [1]. We tried disabling ipython and it seems to be a workaround. I there

ipython/grpc issues

2018-02-14 Thread Ruslan Dautkhanov
I've seen several cases when new ipython interpreter isn't possible to stop using "Cancel" button. Interpreter logs shows following errors. Then paragraph stops accepting Cancel commands and it shows that status as "running" when it's actually not. Python 2.7.13. Zeppelin from a few days old

Clear states and values between runs

2018-02-14 Thread André Schütz
Hi, I have a question about the states and created values within a paragraph that uses the Apache Flink interpreter. If I have the following code: [code] %flink val v1 = // some Flink processing val streamEnvironment = senv streamEnvironment.setStreamTimeCharacteristic

NullPointerException in paragraph when getting batched TableEnvironment

2018-02-14 Thread André Schütz
Hi, within the Flink Interpreter context, we try to get a Batch TableEnvironment with the following code. [code] import org.apache.flink.table.api._ import org.apache.flink.table.api.scala._ import org.apache.flink.table.sources._ val batchEnvironment = benv val batchTableEnvironment =