Top "Apache-zeppelin" questions

Apache Zeppelin is a web-based notebook that enables data-driven interactive data analytics.

export data in csv using zeppelin

I need to export data in csv format from my %sql interpreter in zeppelin. How can I do so? I …

apache-zeppelin
Apache zeppelin tutorial, error "sql interpreter not found"

In the "Zeppelin tutorial" notebook, I can't use the %sql interpreter. It will output "sql interpreter not found". But the …

apache-spark-sql apache-zeppelin
Zeppelin - Cannot query with %sql a table I registered with pyspark

I am new to spark/zeppelin and I wanted to complete a simple exercise, where I will transform a csv …

apache-spark pyspark apache-spark-sql apache-zeppelin
Zeppelin throws java.lang.OutOfMemoryError: Java heap space

I am trying to use Zeppelin with the following code: val dataText = sc.parallelize(IOUtils.toString(new URL("http://XXX.…

apache-spark apache-zeppelin
How to get the output from console streaming sink in Zeppelin?

I'm struggling to get the console sink working with PySpark Structured Streaming when run from Zeppelin. Basically, I'm not seeing …

apache-spark pyspark apache-zeppelin spark-structured-streaming
Is it possible to set global variables in a Zeppelin Notebook?

I'm trying to create a multi-paragraph dashboard using a Zeppelin notebook. I'd like people using the dashboard to only have …

apache-spark apache-zeppelin
Zeppelin Dynamic Form Drop Down value in SQL

I have a dropdown element in my Zeppelin notebook val instrument = z.select("Select Item", Seq(("A", "1"),("B", "2"),("C", "3"))) I …

apache-spark apache-spark-sql apache-zeppelin dynamic-forms
com.fasterxml.jackson.databind.JsonMappingException: Jackson version is too old 2.5.3

My OS is OS X 10.11.6. I'm running Spark 2.0, Zeppelin 0.6, Scala 2.11 When I run this code in Zeppelin I get an …

apache-spark maven-2 spark-streaming apache-zeppelin fasterxml
How to suppress printing of variable values in zeppelin

Given the following snippet: val data = sc.parallelize(0 until 10000) val local = data.collect println(s"local.size") Zeppelin prints out …

scala apache-spark apache-zeppelin
How to fix Py4JJavaError: An error occurred while calling collectToPython

I'm trying to use pyspark interpreter on a zeppelin notebook deployed using Kubernetes. I have configured spark to use spark …

kubernetes pyspark apache-zeppelin py4j