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 wrote:
>
>>
>> Sorry , miss PR l
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 wrote:
>
> Sorry , miss PR link https://github.com/apache/zeppelin/pull/2802
>
>
> Jeff Zhang 于2018年2月15日周四 上午10:30写道：
>
>>
>> HI Ruslan,
>>
>> Could you help
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 Flink Interpreter
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 isn't possible to
>> stop using "Cancel"
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 Cancel commands and it shows
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
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 mas
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
(TimeCharacteristic.Even
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 = Tabl
