在 Zeppelin 中输出“Hello world”失败。
我刚刚安装了来自git仓库的最新源码构建的Apache Zeppelin，并成功地看到它在10008端口上运行。我创建了一个新的笔记本，其中包含一行代码。 val a = "Hello World!" 运行此段落时，出现以下错误: java.net.ConnectException:...
如何在Zeppelin中从控制台流接收器获得输出？
我在使用Zeppelin运行PySpark结构化流时，无法使console输出正常工作。基本上，我没有看到任何结果打印到屏幕上，也没有在我找到的任何日志文件中看到结果。 我的问题是：是否有人有使用PySpark Structured Streaming的工作示例，其中包含一个可在Apache...
什么是Apache Zeppelin？
我们经常听到关于Apache Zeppelin的消息，这让我们想到了一些问题： 什么是Apache Zeppelin？ 它在大数据生态系统中提供了哪些新的和/或额外的功能？ 它是否替代了现有的一些大数据生态系统中的框架/工具？
如何在 Apache Zeppelin 中获取超过 100 的 SQL 结果？
当我在apache-zeppelin中执行这个查询时，只得到了100个结果，并出现了“结果受100个限制”的提示信息。%sql SELECT ip FROM log 我在SQL查询中添加了“Limit 10000”，但仍然只返回了 100 条结果。%sql SELECT ip FROM log...
如何让独立的Zeppelin服务看到Hive？
我正在使用HDP-2.6.0.3版本，但是我需要Zeppelin 0.8版本，所以我已经将其安装为独立服务。当我运行以下命令时： %sql show tables 当我运行Spark2 SQL命令时，没有返回任何结果，并且显示“table not found”错误。但是在HDP中包含的...
如何在EMR集群上使Zeppelin重新启动干净？
我正在运行一个 EMR 集群并尝试使用 Zeppelin 笔记本进行数据分析。 版本信息： 发行标签：emr-5.2.1 Hadoop 分布式系统版本：Amazon 2.7.3 Hive 版本：2.1.0 Spark 版本：2.0.2 Zeppelin 版本：0.6.2 在运行查询时，...
Scala和Spark UDF函数
我编写了一个简单的UDF，用于在spark中从temptabl的时间字段转换或提取一些值。我注册了这个函数，但是当我使用sql调用该函数时，它会抛出NullPointerException异常。以下是我的函数和执行过程。我正在使用Zeppelin。奇怪的是，昨天这个函数还能正常运行，但今天突然...
使用spark-csv在zeppelin中读取csv文件
我想在Zeppelin中读取csv文件，并希望使用databricks的spark-csv软件包：https://github.com/databricks/spark-csv 在spark-shell中，我可以使用以下命令来使用spark-csv：spark-shell --package...
如何将Zeppelin连接到从源代码构建的Spark 1.5？
我从Spark代码库中拉取了最新的源代码并在本地进行了构建。它在类似于spark-shell或spark-sql的交互式shell中运行良好。 现在，我想按照此安装手册将Zeppelin连接到我的Spark 1.5。我将自定义的Spark构建发布到本地maven仓库，并在 Zeppelin ...