Flink 命令行提交、展示和取消作业

在Flink中,可以通过命令行提交、展示和取消作业。以下是如何使用命令行操作Flink作业的示例:

  1. 提交作业
./flink run -c com.example.MainClass /path/to/your/job.jar [jobArgs]

这里,run是提交作业的命令,-c后面跟着的是主类的全路径,接着是jar文件的路径和可选的作业参数。

  1. 展示作业
./flink list

这将列出当前Flink集群中所有运行的作业。

  1. 取消作业
./flink cancel JOB_ID

以上命令假设你在Flink的命令行工具目录下执行,并且你有正确的权限和配置。如果你的Flink集群部署在远程服务器上,你可能需要通过SSH或其他方式连接到远程服务器,然后执行上述命令。

命令行

  1. 启动本地 Flink 集群:
./bin/start-cluster.sh
  1. 停止本地 Flink 集群:
./bin/stop-cluster.sh
  1. 提交一个作业到 Flink 集群运行:
./bin/flink run examples/streaming/WordCount.jar
  1. 停止正在运行的作业:
./bin/flink cancel <job-id>
  1. 列出所有运行的作业:
./bin/flink list
  1. 列出作业的详细信息:
./bin/flink info <job-id>

7/ 列出savepoint能够恢复的作业:

./bin/flink savepoint <job-id> [savepointDirectory]
  1. 从savepoint恢复作业:
./bin/flink run -s :savepointMetaDataPath <program> [<arguments>]
  1. 更新运行中的作业的并行度:
./bin/flink update <job-id> -p <newParallelism>
  1. 从指定的jar或者类运行一个新的程序:
./bin/flink run -c <main-class> <jar-file> <arguments>

注意: 这些命令应在 Flink 安装目录的命令行终端中执行。每个命令的具体参数和用法可以通过在命令后添加 --help 来查看详细的帮助信息,例如:./bin/flink run --help。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/27016.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

深入理解MyBatis XML配置文件

MyBatis是一款优秀的持久层框架&#xff0c;简化了数据库操作的复杂性&#xff0c;提高了开发效率。在MyBatis中&#xff0c;XML配置文件扮演了重要角色&#xff0c;用于配置数据源、事务管理、SQL映射等内容。本文将详细介绍MyBatis的XML配置文件&#xff0c;帮助读者更好地理…

Three.js的渲染器:WebGLRenderer、CSS3DRenderer、SVGRenderer

我们都晓得渲染器是负责将场景中的3D对象转换为2D图像&#xff0c;然后显示在屏幕上&#xff0c;three.js内置了多种渲染器&#xff0c;来应对不同的和需求&#xff0c;贝格前端工场老司机&#xff0c;简要和大家分享下。 一、渲染器的定义和作用 在Three.js中&#xff0c;渲…

凯伦股份中标中铁置业2024-2026年度防水材料框架协议采购项目!

近日&#xff0c;凯伦股份收到了中铁置业集团有限公司发来的中标通知书&#xff0c;确定凯伦公司为其2024年度-2026年度防水材料框架协议采购项目的中标人&#xff0c;正式成为中铁置业集团的合作供应商。 中铁置业集团有限公司是中国中铁股份有限公司的全资子公司&#xff0c;…

【postman接口测试工具的安装和使用】

Postman是一个强大的接口测试和开发工具&#xff0c;支持HTTP协议的所有请求方式&#xff0c;如GET、POST、PUT、DELETE等&#xff0c;并允许用户模拟各种HTTP请求[1][2]。以下是关于Postman的安装和使用方法的详细介绍&#xff1a; 安装Postman 访问官方网站&#xff1a; 打开…

关键的服务器硬件组件及其基本功能

以下是一些关键的服务器硬件组件及其基本功能&#xff1a; 中央处理器&#xff08;CPU&#xff09;&#xff1a; 功能&#xff1a;执行计算和处理任务&#xff0c;是服务器的核心处理单元。特点&#xff1a;通常服务器使用多核、多线程的高性能CPU&#xff0c;以处理并行任务和…

Kafka跨集群数据镜像解决方案MirrorMaker及其替代工具

摘要&#xff1a; 本文介绍了Apache Kafka社区提供的跨集群数据镜像工具MirrorMaker&#xff0c;分析了其优缺点&#xff0c;并简要介绍了LinkedIn和Confluent公司针对MirrorMaker的不足所开发的替代工具。 一、MirrorMaker简介 MirrorMaker是Apache Kafka社区推出的一款跨集…

Llama3-8B到底能不能打?实测对比

前几天Meta开源发布了新的Llama大语言模型&#xff1a;Llama-3系列&#xff0c;本次一共发布了两个版本&#xff1a;Llama-3-8B和Llama-3-70B&#xff0c;根据Meta发布的测评报告&#xff0c;Llama-3-8B的性能吊打之前的Llama-2-70B&#xff0c;也就是说80亿参数的模型干掉了70…

GNU/Linux - 使用字符设备来操作GPIO

从 4.8 版开始&#xff0c;Linux 内核引入了基于字符设备的新用户空间 API&#xff0c;用于管理和控制 GPIO&#xff08;通用输入/输出&#xff09;。这篇文章介绍了新接口的基本原理&#xff0c;并通过一个简单的教程/示例演示了如何使用新 API 控制 GPIO。 教程中使用的硬件是…

一篇文章教你学会如何用云服务器搭建https网站

首先我们要明白为什么要通过云服务器来搭建https网站&#xff0c;这是因为通过使用云服务器搭建 HTTPS 网站&#xff0c;可以为我们提供更高的安全性和信任度。 一&#xff0c;前期的准备工作分为三大类&#xff1a;一台云服务器&#xff0c;域名&#xff0c;SSL证书&#xff1…

ESP8266发送WOL幻数据包实现电脑远程唤醒

计算机远程唤醒&#xff08;Wake-on-LAN, WOL&#xff09; 计算机远程唤醒&#xff08;Wake-on-LAN&#xff0c;简称 WOL&#xff09;是一种局域网唤醒技术&#xff0c;可以将局域网内处于关机或休眠状态的计算机唤醒至引导&#xff08;Boot Loader&#xff09;或运行状态。无…

RAG 实践-Ollama+AnythingLLM 搭建本地知识库

什么是 RAG RAG&#xff0c;即检索增强生成&#xff08;Retrieval-Augmented Generation&#xff09;&#xff0c;是一种先进的自然语言处理技术架构&#xff0c;它旨在克服传统大型语言模型&#xff08;LLMs&#xff09;在处理开放域问题时的信息容量限制和时效性不足。RAG的…

pg——psql命令行交互式客户端工具

1、启动数据库 ./pg_ctl -D /usr/local/pgsql/data/ -l /usr/local/pgsql/log 2、登录数据库 psql template1 3、查看所有数据库 \l 4、创建数据库 create database testdb; 5、连接某数据库 \c 数据库 6、查看数据下的表 \d 7、 查看数据库下的所有schema \dn 8、查看表的结构…

BSV及BTC减半来袭,Teranode如何确保节点未来依然有足够的收入

​​发表时间&#xff1a;2024年4月12日 随着BTC第四次区块奖励减半的完成&#xff0c;加密资产行业正处于某种程度的狂热之中。这使得与扩容以及经济可持续性相关的讨论日益增加。 BTC价格的波动性强是众所周知的&#xff0c;经常几分钟内价格突然飙升或急速下跌&#xff0c;…

wmv转换mp4怎么操作?3个格式转换方法分享

wmv转换mp4怎么操作&#xff1f;将WMV转换为MP4格式&#xff0c;可以方便我们在多种设备和平台上流畅播放视频。MP4格式具有广泛的兼容性和优化过的编码&#xff0c;使其在各种媒体播放器、智能手机、平板电脑以及电视上都能得到良好的支持。此外&#xff0c;MP4格式的视频文件…

Spring Boot集成tablesaw插件快速入门Demo

1 什么是tablesaw&#xff1f; Tablesaw是一款Java的数据可视化库&#xff0c;主要包括两部分&#xff1a; 数据解析库&#xff0c;主要用于加载数据&#xff0c;对数据进行操作(转化&#xff0c;过滤&#xff0c;汇总等)&#xff0c;类比Python中的Pandas库&#xff1b; 数据…

网络安全(补充)

针对网络信息系统的容灾恢复问题&#xff0c;国家制定和颁布了《信息安全技术信息系统灾难恢复规范&#xff08;GB/T 20988-2007&#xff09;》&#xff0c;该规范定义了六个灾难恢复等级和技术要求&#xff1a;第一级基本支持&#xff08;要求至少每周做一次完全数据备份&…

linux yum 安装mysql

安装过程 yum -y install mysql mysql-server mysql-devel systemctl start mysqld.service 启动 netstat -lnp|grep 3306 查看端口 systemctl status mysqld.service 查看状态 mysql -uroot -p 登录mysql&#xff0c;输入密码可以直接回车&#xff0c;如果登录在失败在查找…

上海晋名室外危废品暂存柜助力储能电站行业危废品安全储存

近日又有一台SAVEST室外危废暂存柜项目成功验收交付使用&#xff0c;此次项目主要用于储能电站行业废油、废锂电池等危废品的安全储存。 用户单位在日常工作运营中涉及到废油、废锂电池等危废品的室外安全储存问题。4月中旬用户技术总工在寻找解决方案的过程中搜索到上海晋名的…

深入剖析ReentrantLock的FairSync:公平锁机制的源码之旅

1. 引言 在Java并发编程中,ReentrantLock作为一种功能强大的可重入锁,提供了公平与非公平两种锁机制。其中,FairSync作为ReentrantLock内部实现公平锁机制的关键组件,其设计理念和源码实现都值得深入探讨。 2. NonfairSync概述 ReentrantLock是Java提供的一个互斥锁,具有…

华为wlan实验

分为三步&#xff1a;1、网络互通&#xff0c;2、AP上线&#xff0c;3、wlan业务 1、网络互通 crow-sw: vlan batch 20 100 dhcp enable int vlan 20 ip add 192.168.20.1 24 dhcp select interfaceinterface GigabitEthernet0/0/2port link-type accessport default vlan 100…