【发布时间】:2018-05-09 08:33:06
【问题描述】:
我有一个 Zeppelin 笔记本“测试”。这个笔记本有 2 个段落,如下所示
1.
%spark
import statements;
val df=sqlContext.read.format....cassandra..table
df.registerTempTable("users")
2.
%spark.sql
select date,count(users) from users
我安排此笔记本每 5 分钟运行一次。在第一次运行时,我从第二段中收到错误,即找不到“用户”表。
我需要将依赖项添加到第二段,以便第二段仅在第一段完成时运行。如何在 Zeppelin 0.6.0 中实现这一点?
【问题讨论】:
-
面临类似的问题。任何建议将不胜感激
-
你找到解决办法了吗?我找不到任何解决方案
标签: apache-zeppelin