二百八十四、Flink——Flink提交任务两种方式(亲测、附截图)

ops/2025/1/18 11:50:50/

一、目的

在IDEA中开发好项目后,如何在Flink上提交打包的jar包,有两种方式,分别是WEB UI 界面提交和通过命令行来提交

二、WEB UI 界面提交方式

1 在Submit New Job,点击右侧的+Add New,上传打包好的jar包

2 点击刚才上传的jar包,输入全类名和分区数

注意:由于我是单机环境,因为分区只能为1,否则会报错。这是一坑

          如果是集群,那分区数不超过集群数即可

3.点击Submit提交后,可以看到运行状态

4.端口输入数据,在Task Managers里可以看到

5.取消任务

在Running Jobs,点击运行任务,点击右侧的Cancel Job,就可以取消任务

6.在Completed Jobs查看结束的任务状态

三、命令行提交方式

1、打好的jar包上传Linux的flink安装路径下

2、执行Linux命令

# bin/flink run -m hurys23:8081 -c com.atguigu.chapter02.StreamWordCount ./FlinkTutorial-1.0-SNAPSHOT.jar

3.Running Jobs可以查看服务

4.端口输入数据TaskManager 看到结果

5.命令行取消任务

# ./bin/flink cancel 9d77b78eb8fd218248fea1f4e2c99e3c

6.在Completed Jobs查看结束的任务状态

搞定!开启Flink学习阶段


http://www.ppmy.cn/ops/151076.html

相关文章

NumPy;NumPy在数据分析中的应用;NumPy与其他库的搭配使用

NumPy;NumPy在数据分析中的应用;NumPy与其他库的搭配使用 NumPy:Python 数据分析的核心工具什么是 NumPy?NumPy 的主要优势 NumPy 在数据分析中的应用1. 数据处理与清洗2. 数学和统计分析3. 数组变换与矩阵运算 NumPy 与其他库的搭…

56_多级缓存实现

1.查询Tomcat 拿到商品id后,本应去缓存中查询商品信息,不过目前我们还未建立Nginx、Redis缓存。因此,这里我们先根据商品id去Tomcat查询商品信息。此时商品查询功能的架构如下图所示。 需要注意的是,我们的OpenResty是在虚拟机,Tomcat是在macOS系统(或Windows系统)上,…

GitLab 国际站中国大陆等地区停服,如何将数据快速迁移到云效

代码托管平台 GitLab 国际站(GitLab.com)近日发布公告,官宣即将停止对中国大陆、香港、澳门地区的用户账号提供服务,并提供 60 天过渡期自行迁移账户数据,超期未迁移的账号可能会被 GitLab 清除。这一重要决策引起了全…

openharmony电源管理子系统

电源管理子系统 简介目录使用说明相关仓 简介 电源管理子系统提供如下功能: 重启服务:系统重启和下电。系统电源管理服务:系统电源状态管理和休眠运行锁管理。显示相关的能耗调节:包括根据环境光调节背光亮度,和根…

Redis系列之底层数据结构整数集IntSet

Redis系列之底层数据结构整数集IntSet 什么是IntSet IntSet,整数集合,是Redis集合类型的一种底层数据结构,当一个集合只包含整数值元素,并且这个集合的元素数量不多时,redis就会选用intset作为底层实现。 IntSet的数…

RabbitMQ与Kafka的比较及应用

引言 在构建分布式系统和微服务架构时,数据库与中间件的选择至关重要。它们不仅是数据流转的桥梁,更是确保系统高效、稳定运行的关键组件。本文将深入探讨两种流行的消息中间件——RabbitMQ与Kafka,从架构特点、优势、应用场景到常见问题解决…

【Uniapp-Vue3】showActionSheet从底部向上弹出操作菜单

底部弹出选择框: uni.showActionSheet({ title:"标题", itemList:选择数组, success:res>{ // 获得res.tapIndex进行操作 } }) 依次选择“高中”,“大专”,“本科”,“研究生” ,下标分别为0,…

服务器卡顿是否等同于遭受CC攻击?

在网站运营或应用服务过程中,遇到服务器响应缓慢或者卡顿时,很多管理员的第一反应是可能遭遇了CC(Challenge Collapsar)攻击。但实际情况往往更为复杂。本文将探讨服务器卡顿与CC攻击之间的关系,并提供一些基本的排查方…