Flink on zeppelin 初试

1,安装好Zeppelin之后 配置 好 Flink Interpreters

2,我这里安装的是remote模式:

Flink on zeppelin 初试

 

3,执行自带案例是否可以正常执行:

Flink on zeppelin 初试

 

4,做一个查询kafka的案例

1)先导入依赖

Flink on zeppelin 初试

这里的格式类似是 groupid:artId:版本

Flink on zeppelin 初试

然后要去重启 interpreter 

Flink on zeppelin 初试

 

Flink on zeppelin 初试

 

并且在节点监控zeppelin的日志:

Flink on zeppelin 初试

耐心等待一下:

 

执行:

Flink on zeppelin 初试

继续执行下一个

Flink on zeppelin 初试

最后执行查询:

Flink on zeppelin 初试