千家信息网

Flink如何使用

发表于:2025-12-01 作者:千家信息网编辑
千家信息网最后更新 2025年12月01日,本篇内容介绍了"Flink如何使用"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1、首先拉取镜像do
千家信息网最后更新 2025年12月01日Flink如何使用

本篇内容介绍了"Flink如何使用"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

1、首先拉取镜像

docker pull flink

2、创建一个docker的network

docker network create flink-network

3、运行容器

docker run --rm --name=jobmanager --network flink-network --publish 8081:8081 --env FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager" flink:latest jobmanager

4、然后直接访问 http://localhost:8081/ 能访问进去,就完事了。使用,等会用了再来补充。

用容器提交任务老半天提交不上去,后来在本地安装了一个,由于是windos的,所有下载了一个1.9.3的版本下载的。

1、运行很简单,直接找到bin目录,然后双击运行即可。

2、然后提交任务的时候出现Entry Class没有的话,表示没有主目录,也就是打包的时候没有指定main函数导致的,配置中可以设置下主目录即可。

3、然后提交任务,点击show plan会报错,提交任务也报错。可以在Job Manage菜单看到Logs点进去,拉到最下面发现有报错信息,都是缺少类,这个狗日的问题困扰了老半天,百度找不到,我觉得应该是很低级的问题,可能很少犯(起码版本问题,但实际上并不是)。后面找到些博客说是在lib下添加引用类,老子用的pom又不是直接引用的jar。后面发现flink有个lib文件夹,就把jar丢进去了,发现虽然还是缺少类,但是缺少的类变了。然后我尝试打包所有的依赖项到一个jar,错误变了,但是依旧是缺少类。后面又找了很久的博客,忘记记下地址了,说打包时候并不是所有的依赖都要打包,然后给出了一个maven的打包信息,然后试了下,好了。只想说一句MMP,这问题应该很多人记录才对,但是都没有记录,那我就记录下吧。后面再补充报错信息。

                        org.apache.maven.plugins            maven-shade-plugin            3.0.0                                                package                                            shade                                                                                                                            com.google.code.findbugs:jsr305                                org.slf4j:*                                log4j:*                                                                                                                                                                        *:*                                                                    META-INF/*.SF                                    META-INF/*.DSA                                    META-INF/*.RSA                                                                                                                                                                        com.uwith.Application                                                                                                                

"Flink如何使用"的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!

任务 问题 信息 时候 目录 运行 内容 博客 实际 容器 更多 版本 知识 低级 实用 学有所成 接下来 也就是 函数 困境 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 db2数据库中的package 猿宝互联网科技公司怎么样 天津铭航网络技术有限公司 公寓 青桔共享单车服务器繁忙 江苏c语言软件开发服务费 数据库的详细设计 命令备份数据库 深度学习卷积神经网络技术与实践 深度神经网络技术的具体应用 淄博张店网络安全张召峰简历 汕尾卫星软件开发优化价格 ftp服务器 安全吗 数据互通服务器 高校网络安全人员管理制度 数据库备份系统软件免费正式版 数据库第三范式跨越到第四 mysql数据库集群原理 计算机软件开发对日方向 福建棋牌软件开发公司有哪些 软件开发web是哪个专业 华为网络安全工程师入职培训 qq为什么总是与服务器断联 大学网络安全视频下载 青岛西海影电网络技术有限公司 教育软件开发职业 高校网络安全人员管理制度 5g网络安全困境 有网红和网络安全吗 网络安全预算项目 战地1怎么看服务器名字
0