Flink SQL Cookbook on Zeppelin 部署使用

news/2024/12/25 10:00:43 标签: flink, notebook, zeppelin, 示例, 手册

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

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

1.准备环境

flinkSQLcookbookonzeppelin_5">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
在这里插入图片描述

flink_37">2.2 flink配置

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

2.3 使用

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


http://www.niftyadmin.cn/n/5798950.html

相关文章

Android 之 List 简述

一、简单创建方式 Android 开发中&#xff0c;列表有很多种类&#xff0c;如ArrayList、LinkedList、List、MutableList等&#xff0c;创建列表的方式如下所示&#xff1a; fun listDemo() {// 使用 listOf 创建不可变的空列表val list listOf<Int>()val list1 listOf…

抖音视频下载去水印工具推荐

下载抖音视频并去水印的工具有很多&#xff0c;下面推荐几种常用且有效的方法。请注意&#xff0c;下载和去水印的视频需遵守版权和平台规定&#xff0c;避免侵犯原创者权益。 在线工具 这些工具无需安装&#xff0c;可以直接在浏览器中使用&#xff0c;操作简单&#xff1a;…

【Chrome】浏览器提示警告Chrome is moving towards a new experience

文章目录 前言一、如何去掉 前言 Chrome is moving towards a new experience that allows users to choose to browse without third-party cookies. 这是谷歌浏览器&#xff08;Chrome&#xff09;关于隐私策略更新相关的提示 提示&#xff1a;以下是本篇文章正文内容&…

步进电机位置速度双环控制实现

步进电机位置速度双环控制实现 野火stm32电机教学 提高部分-第11讲 步进电机位置速度双环控制实现(1)_哔哩哔哩_bilibili PID模型 位置环作为外环,速度环作为内环。设定目标位置和实际转轴位置的位置偏差,经过位置PID获得位置期望,然后讲位置期望(位置变化反映了转轴的速…

[机器学习]sklearn入门指南(1)

简介 scikit-learn&#xff08;简称sklearn&#xff09;是一个开源的Python机器学习库&#xff0c;它提供了简单而高效的工具用于数据挖掘和数据分析&#xff0c;并且拥有一个活跃的开发社区。它建立在NumPy、SciPy和matplotlib这些科学计算库之上&#xff0c;旨在提供一致且可…

【vue】圆环呼吸灯闪烁效果(模拟扭蛋机出口处灯光)

效果图先发&#xff1a; 页面部分&#xff1a; <div ref"round" class"round"><div class"light" ref"light"/><div class"box"></div></div>js部分(控制圆环生成&#xff09;; setRound…

解释 Python 中的装饰器及其作用?

一、装饰器的基本概念 装饰器本质上是一个函数&#xff0c;它接受一个函数作为参数&#xff0c;并返回一个新的函数。 这个新的函数通常会在原函数的基础上添加一些额外的功能&#xff0c;比如日志记录、权限验证、性能统计等。 装饰器的语法糖形式为decorator_name&#xf…

微信小程序中momentjs无法切换中文问题处理

微信小程序中momentj.s无法切换中文问题处理. 表现为 使用 locale(“zh-cn”)无效。 处理方法 # 1、先删除 miniprogram_npm\moment\index.js # 2、将 node_modules\moment\min\moment-with-locales.min.js 复制到 miniprogram_npm\moment下 并重命名为index.js # 3、修改mi…