Flink on zeppelin 初试
1,安装好Zeppelin之后 配置 好 Flink Interpreters
2,我这里安装的是remote模式:
3,执行自带案例是否可以正常执行:
4,做一个查询kafka的案例
1)先导入依赖
这里的格式类似是 groupid:artId:版本
然后要去重启 interpreter
并且在节点监控zeppelin的日志:
耐心等待一下:
执行:
继续执行下一个
最后执行查询:
1,安装好Zeppelin之后 配置 好 Flink Interpreters
2,我这里安装的是remote模式:
3,执行自带案例是否可以正常执行:
4,做一个查询kafka的案例
1)先导入依赖
这里的格式类似是 groupid:artId:版本
然后要去重启 interpreter
并且在节点监控zeppelin的日志:
耐心等待一下:
执行:
继续执行下一个
最后执行查询: