Apache Zeppelin

综述

Zeppelin任务类型，用于创建并执行Zeppelin类型任务。worker 执行该任务的时候，会通过Zeppelin Cient API触发Zeppelin Notebook Paragraph。 点击这里 获取更多关于Apache Zeppelin Notebook的信息。

创建任务

  • 点击项目管理-项目名称-工作流定义，点击”创建工作流”按钮，进入DAG编辑页面。
  • 工具栏中拖动 Apache Zeppelin - 图1 到画板中，即可完成创建。

任务参数

任务参数描述
Zeppelin Note IDZeppelin Note对应的唯一ID
Zeppelin Paragraph IDZeppelin Paragraph对应的唯一ID。如果你想一次性调度整个note，这一栏不填即可
Zeppelin Rest Endpoint您的Zeppelin服务的REST Endpoint
Zeppelin Production Note Directory生产模式下存放克隆note的目录
Zeppelin Parameters用于传入Zeppelin Dynamic Form的参数

生产（克隆）模式

  • 填上Zeppelin Production Note Directory参数以启动生产模式。
  • 在生产模式下，目标note会被克隆到您所填的Zeppelin Production Note Directory目录下。 Zeppelin任务插件将会执行克隆出来的note并在执行成功后自动清除它。 因为在此模式下，如果您不小心修改了正在被Dolphin Scheduler调度的note，也不会影响到生产任务的执行， 从而提高了稳定性。
  • 如果您选择不填Zeppelin Production Note Directory这个参数，Zeppelin任务插件将会执行您的原始note。 ‘Zeppelin Production Note Directory’参数在格式上应该以斜杠开头和结尾，例如 /production_note_directory/。

任务样例

Zeppelin Paragraph 任务样例

这个示例展示了如何创建Zeppelin Paragraph任务节点：

demo-zeppelin-paragraph

demo-get-zeppelin-id