当前位置： 首页 > article >正文

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

article 2025/1/18 3:21:10

一、目的

在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.kler.cn/a/507287.html

相关文章：

  • 【算法】枚举
  • Java中的依赖注入是什么？它如何工作？
  • YOLOv10-1.1部分代码阅读笔记-build.py
  • HunyuanVideo 文生视频模型实践
  • 网络安全 | 什么是威胁情报？
  • 【机器学习】制造业转型：机器学习如何推动工业 4.0 的深度发展
  • 去中心化身份验证：Web3如何确保元宇宙中的身份安全
  • 如何在gitlab cicd中实现每月10号上午执行
  • 我的世界-与门、或门、非门等基本门电路实现
  • 70_Redis数据结构-RedisObject
  • 有效提取激光雷达点云平面点
  • 字符串dp系列
  • SC34018 免提手柄式扬声电话系统
  • 生产管理看板助力节能科技公司实现数据自动化管理
  • PostMan测试webSocket接口(保姆级教程)
  • 浅谈云计算16 | 存储虚拟化技术
  • 力扣第 54 题: 螺旋矩阵
  • Js：正则表达式及其方法
  • 基于单片机的语音控制玩具汽车的设计
  • UE5 gas制作平A，冷却，打击伤害
  • Fabric区块链网络搭建：保姆级图文详解
  • C#在Json序列化时将key和value转为对应的中文
  • jmeter事务控制器-勾选Generate Parent Sample
  • 基于单片机的智能计步器电路设计
  • Flink Standalone 方案中解决挂机问题
  • 树莓派5--系统问题汇总