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 使用

启动:

当出现当前时间的模拟数据时,系统正常运行:

相关文章:
Flink SQL Cookbook on Zeppelin 部署使用
简介:对于初学者来说,学习 Flink 可能不是一件容易的事情。看文档是一种学习,更重要的是实践起来。但对于一个初学者来说要把一个 Flink SQL 跑起来还真不容易,要搭各种环境,真心累。很幸运的是,Flink 生态…...
【hackmyvm】DC04靶机wp
created: 2024-12-04 23:08 tags: HMV黄金票据PTTntlm中毒 难度: ⭐️⭐️⭐️⭐️⭐️ 作者: josemlwdf 系统: Windows 1. 基本信息^toc 文章目录 1. 基本信息^toc2. 信息收集2.1. 端口扫描2.2. 目录扫描2.3. 网址利用 3. websvc用户3.1. NTLM中毒攻击3.2. smb探测 4. rtina9…...
记录jvm进程号
日常开发中,相信大家会经常用到这么一行命令: ps -ef | grep xxx.jar | grep -v grep | awk {print $2} | xargs -r kill -9 就是杀掉xxx相关的进程,然后启动,当然也还有其他的方式可以实现类似的功能,我就不列举了&…...
day19——web自动化测试(1)
【没有所谓的运气🍬,只有绝对的努力✊】 目录 1、什么是自动化 1.1 概念: 1.2 优点: 2、什么是自动化测试 2.1 自动化测试能解决什么问题? 2.1.1 优点: 2.1.2 误区: 2.2 自动化测试分类…...
go window安装protoc protoc生成protobuf文件
1. 下载: Releases protocolbuffers/protobuf GitHub 2. 解压缩: 3. 配置环境变量: 选择系统变量->Path -> 新增 解压缩后的bin路径 4. 打印版本: protoc --version 5. 安装protoc-gen-go cmd 下输入安装命令࿰…...
微信小程序中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…...
数据结构:链表
链表是一种常见的数据结构,它由一系列节点(Node)组成,每个节点包含两个部分:数据域和指针域。数据域用于存储数据元素的值,而指针域则用于指向链表中的下一个节点。这种结构使得链表能够动态地进行插入和删…...
领克Z20结合AI技术,革新自动驾驶辅助系统
眼瞅着,再有不到 5 个星期,春节就要热热闹闹地登场啦!对于在外辛苦打拼了一整年的打工人而言,回家过年可不就是这一年里心心念念、最最期盼的高光时刻嘛。这不,这几天各地的高速公路愈发熙熙攘攘起来,川流不…...
vector快慢指针+例题详解
1.快慢指针 例题 给定一个链表,判断链表中是否有环。 如果链表中有某个节点,可以通过连续跟踪 next 指针再次到达,则链表中存在环。 为了表示给定链表中的环,我们使用整数 pos 来表示链表尾连接到链表中的位置(索引从…...
重温设计模式--1、组合模式
文章目录 1 、组合模式(Composite Pattern)概述2. 组合模式的结构3. C 代码示例4. C示例代码25 .应用场景 1 、组合模式(Composite Pattern)概述 定义:组合模式是一种结构型设计模式,它允许你将对象组合成…...
单片机:实现SYN6288语音播报(附带源码)
单片机实现SYN6288语音播报 SYN6288是一款广泛应用于语音合成的IC,可以通过串口与单片机(如51系列、STM32等)进行通信,实现场景化的语音播报。通过连接外部存储设备(如SD卡)存储语音文件或直接通过内部语音…...
cookie,session,token 的区别
解决什么问题?Cookie(客户端存储)问题来了 Session(会话)解决的问题问题来了 token(令牌)解决的问题问题:token是无状态的如何解决? 解决什么问题? 解决http无状态的问题,说简单点就是用户身份的验证 举个例子: 张三在银行里…...
基于OpenAI Whisper AI模型自动生成视频字幕:全面解析与实战指南
在数字化时代,视频内容已成为信息传播的重要载体。然而,为视频添加字幕却是一项繁琐且耗时的工作。幸运的是,随着人工智能技术的飞速发展,特别是OpenAI Whisper模型的推出,我们有了更加高效、智能的解决方案。 一、Op…...
物理学天空的两朵乌云——量子论与相对论
物理学天空的两朵乌云——量子论与相对论 爱因斯坦的青春与科学的辉煌起点 提到爱因斯坦,我们往往会联想到一个经典的形象——乱糟糟的头发,叼着烟斗,脸上满是岁月的皱纹。然而,这张深入人心的照片并不是他科学创造力的象征。实…...
聚类之轮廓系数
Silhouette Score(轮廓系数)是用于评估聚类质量的指标之一。它衡量了数据点与同簇内其他点的相似度以及与最近簇的相似度之间的对比。 公式 对于一个数据点 i: a(i): 数据点 i 到同簇内其他点的平均距离(簇内不相似度ÿ…...
Jenkins 构建流水线
在 Linux 系统上安装 Jenkins 服务,以及配置自动化构建项目 前置准备环境:docker、docker-compose、jdk、maven 一、环境搭建 1. Jenkins 安装 (1)拉取镜像 # 安装镜像包,默认安装最新版本 docker pull jenkins/jen…...
RTK部分模糊度固定测量流程图
部分模糊度剔除常用测量: 周跳或失锁时间优先剔除;按俯仰角剔除;按浮点模糊度协方差大小剔除模糊度;按信号强度剔除卫星;...
力扣-数据结构-2【算法学习day.73】
前言 ###我做这类文章一个重要的目的还是给正在学习的大家提供方向(例如想要掌握基础用法,该刷哪些题?建议灵神的题单和代码随想录)和记录自己的学习过程,我的解析也不会做的非常详细,只会提供思路和一些关…...
操作系统导论读书笔记
目录 虚拟化抽象:进程抽象:进程概念 虚拟化 抽象:进程 本章讨论操作系统提供的基本的抽象—— 进程。进程的非正式定义非常简单:进程就是运行中的程序。程序本身是没有生命周期的,它只是存在磁盘上面的一些指令&…...
基于3D-Speaker进行区分说话人项目搭建过程报错记录 | 通话录音说话人区分以及语音识别 | 声纹识别以及语音识别 | pyannote-audio
0. 研究背景 在外呼系统中,我们的后台管理系统通常要对电话录音的内容进行提取和分析。那么说到分析,我们就要对录音中的两个人的对话进行分离,然后分别分析,比如分析客户是否有合作的意愿,分析客服讲的话术是否合理&…...
大模型实习复盘:GPT老师带你一个个接口硬啃
总结:互联网中厂大厂,尤其是给你权限给你机器玩的,去,提升极大。小公司or普通研究院,非常一般。一段实习,通常需要满足一些前置的技术条件才能拿到offer。但offer只是开始,还需要自己有意识地在…...
调参不再玄学:手把手教你优化智能车(电磁组)舵机PD控制参数,告别‘画龙’
智能车电磁组舵机控制实战:从参数原理到赛道调优的完整指南 当你的智能车在直道上像喝醉一样左右摇摆,或者在弯道犹豫不决时,大多数问题都指向同一个核心——舵机控制参数设置不当。这不是魔法,而是一门可以通过系统方法掌握的科学…...
intv_ai_mk11惊艳效果:同一提示词下不同温度值生成结果的语义与风格对比
intv_ai_mk11惊艳效果:同一提示词下不同温度值生成结果的语义与风格对比 1. 模型效果展示概述 intv_ai_mk11作为基于Llama架构的文本生成模型,其温度参数(temperature)对生成结果的多样性和创造性有着显著影响。温度值控制着模型在生成文本时的随机性程…...
Arcgis新手必看:如何用线矢量快速提取tif栅格值并绘制专业剖面线图
ArcGIS线矢量提取栅格值实战:从数据到专业剖面图的完整指南 当你第一次面对需要分析地形起伏、温度梯度或任何连续空间数据的变化趋势时,剖面线图无疑是直观展示这些信息的利器。作为ArcGIS平台的核心分析功能之一,线矢量提取栅格值并绘制剖面…...
从教程到产品:基于cursor实战案例,用快马一键生成可部署的管理后台
最近在跟着cursor教程学习React实战开发,发现很多教程虽然步骤详细,但学完后总感觉离实际产品还差一口气。于是尝试用InsCode(快马)平台把教程案例快速转化为可部署的原型,效果意外地好。这里以博客管理后台为例,分享从学习到落地…...
2025年大模型年度复盘:RL、Agent与Omni的技术趋势解读
一、项目介绍准备 项目 1:基于 RAG 的大语言模型关系抽取 1、为什么不用传统语义相似度检索,改用关系原型检索? 传统相似度检索易召回伪近邻样本(语义相近、头尾实体不同→关系不同),干扰模型判断。 我先把…...
告别熬夜!揭秘CSDNer私藏的PPT生成神器
一、PPT 制作之痛:传统与现状在日常的工作与学习中,PPT(PowerPoint)演示文稿已然成为信息展示和沟通的重要工具。无论是商务汇报、学术演讲,还是课堂教学,一份制作精良的 PPT 都能极大地提升信息传递的效果…...
终极指南:Helix Toolkit - 专业级.NET 3D图形框架完全解析
终极指南:Helix Toolkit - 专业级.NET 3D图形框架完全解析 【免费下载链接】helix-toolkit Helix Toolkit is a collection of 3D components for .NET. 项目地址: https://gitcode.com/gh_mirrors/he/helix-toolkit 你是否曾为.NET平台上的3D图形开发感到困…...
双向链表添加节点实现分析
链表节点结构class Node {private Object obj;private Node pre;private Node next;public Node(Object obj, Node pre, Node next) {this.obj obj;this.pre pre;this.next next;} }节点包含三个字段:存储数据的obj,指向前驱节点的pre,指向…...
2026加密算法全景解析:从原理到实战,一文读懂加密的核心逻辑
在数字化时代,数据就是核心资产——从手机支付的交易信息、社交软件的私密聊天,到企业的客户数据、政府的敏感文件,每一份数据的安全都离不开加密算法的守护。我们每天都在接触加密:打开HTTPS网页、登录账号、传输文件,…...
