当前位置: 首页 > news >正文

Flink SQL Cookbook on Zeppelin 部署使用

简介:对于初学者来说,学习 Flink 可能不是一件容易的事情。看文档是一种学习,更重要的是实践起来。但对于一个初学者来说要把一个 Flink SQL 跑起来还真不容易,要搭各种环境,真心累。很幸运的是,Flink 生态圈里有这样一款工具可以帮助你更有效率地学习 Flink:Zeppelin。

相关类似文章较多,但相关依赖环境也给准备好的较少,故做此文。

1.准备环境

1.1 下载flink-SQL-cookbook-on-zeppelin

这个 repo 里是一些 Zeppelin notebook,里面都是 flink-SQL-cookbook 里的例子。
git下载:

git clone https://github.com/zjffdu/flink-SQL-cookbook-on-zeppelin.git

csdn下载(免积分):flink-SQL-cookbook-on-zeppelin

下载好,放到“/home”下,如下图所示:
在这里插入图片描述

1.2 下载 Flink

下载 Flink 1.12.1,已集成 flink-faker-0.2.0.jar(lib目录下)。
csdn下载(免积分):flink-SQL-cookbook-on-zeppelin

下载好,放到“/home”下,如下图所示:
在这里插入图片描述

1.3 docker运行

docker环境搭建,可参考:一键安装docker环境:docker、docker-compose

docker镜像如果不能在镜像仓库下载,可以到我的网盘下载:https://pan.baidu.com/s/17f0Vl2cd7gRIlOfP3wZ1xQ?pwd=mc2k

docker命令:

docker run -d -p 8081:8081 -p 8080:8080 --rm -v $PWD/logs:/logs -v /home/flink-sql-cookbook-on-zeppelin-main/:/notebook -v /home/flink-1.12.1/:/flink -e ZEPPELIN_LOG_DIR='/logs' -e ZEPPELIN_NOTEBOOK_DIR='/notebook' --name zeppelin apache/zeppelin:0.9.0

2.体验 Flink SQL Cookbook 教程

2.1 访问

浏览器访问:http://ip:8080
在这里插入图片描述

2.2 flink配置

这是 Zeppelin 的 UI,里面已经有了一个文件夹 Flink SQL Cookbook,内含所有 Flink SQL 教程。首先我们需要配置下 Flink 解释器,点击右上角的菜单,选择 interpreter,找到 Flink interpreter,修改其中的 FLINK_HOME 为 /flink (也就是上面 docker 命令里我们挂载的 flink),然后点击重启 interpreter。
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

2.3 使用

在这里插入图片描述
启动:
在这里插入图片描述
当出现当前时间的模拟数据时,系统正常运行:
在这里插入图片描述

http://www.lryc.cn/news/509510.html

相关文章:

  • 【hackmyvm】DC04靶机wp
  • 记录jvm进程号
  • day19——web自动化测试(1)
  • go window安装protoc protoc生成protobuf文件
  • 微信小程序中momentjs无法切换中文问题处理
  • 数据结构:链表
  • 领克Z20结合AI技术,革新自动驾驶辅助系统
  • vector快慢指针+例题详解
  • 重温设计模式--1、组合模式
  • 单片机:实现SYN6288语音播报(附带源码)
  • cookie,session,token 的区别
  • 基于OpenAI Whisper AI模型自动生成视频字幕:全面解析与实战指南
  • 物理学天空的两朵乌云——量子论与相对论
  • 聚类之轮廓系数
  • Jenkins 构建流水线
  • RTK部分模糊度固定测量流程图
  • 力扣-数据结构-2【算法学习day.73】
  • 操作系统导论读书笔记
  • 基于3D-Speaker进行区分说话人项目搭建过程报错记录 | 通话录音说话人区分以及语音识别 | 声纹识别以及语音识别 | pyannote-audio
  • 如何使用流式渲染技术提升用户体验
  • 【接口自动化连载】使用yaml配置文件自动生成接口case
  • 前端安全 常见的攻击类型及防御措施
  • 来道面试题——CopyOnWriteArrayList
  • 【Rust自学】5.1. 定义并实例化struct
  • React 生命周期完整指南
  • python中os._exit(0) 强制关闭进程后来杀死线程
  • LeetCode:257. 二叉树的所有路径
  • RSICV国产芯片之CHV208
  • 理解神经网络
  • Android 之 List 简述