flink常用命令

摘要:
1.查看flash任务/var/lib/hadop hdfs/link/bin/linklist 2.停止flash任务/var/lib/hadop hdfs/link/bin/linkcanceljobId 3.启动yarnsessionbin/yarn-session。sh-d-d-jm2048-tm6144-quroot.sparkstreating nmflash_dev_p

1.查看flink任务

/var/lib/hadoop-hdfs/flink/bin/flink  list

2.停止flink任务

/var/lib/hadoop-hdfs/flink/bin/flink  cancel  job Id

3.启动一个yarn session

bin/yarn-session.sh -d -s 3 -jm 2048 -tm 6144 -qu root.sparkstreaming -nm  flash_dev_pv_uv

4.查看yarn session

yarn application --list

5.杀掉yarn session

yarn appclication -kill application_1625727533919_9502

6.启动flink job

/var/lib/hadoop-hdfs/flink/bin/flink run -p 6  -c com.code2144.flashOverwrite.FashDevPVAndUVFunction

-yid application_1630824298449_96210 /var/lib/hadoop-hdfs/flink/jars/flash_dev_pv_uv/BSS-ONSS-Flink-1.0-SNAPSHOT.jar

6.1指定checkpoint启动

/var/lib/hadoop-hdfs/flink/bin/flink run -p 8 -s hdfs://bigdata/flink/checkpoints/workFlowCheckpoint/75f16ca2cebdc1a636370eede87ac497/chk-4066916/_metadata

-c com.code2144.helper_workflow.HelperWorkFlowStreaming -yid application_1625727533919_9494 /var/lib/hadoop-hdfs/flink/jars/BSS-ONSS-Flink-1.0-SNAPSHOT.jar

免责声明:文章转载自《flink常用命令》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇mysql 行转列javaweb之Cookie篇下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

javascript 使用数据加密跟base64 编码

下面的js代码首先将给定的数据字符串,跟指定的密匙字符串做异或运算,接着将结果序列进行base64编码,下面同时给出了解密算法跟,base64还原函数 代码如下: function secode(opArray) {var _local2 = opArray;var strEnd="=";var _local3 = "ABCDEFGHIJKLMNOPQR...

解决Flink消费Kafka信息,结果存储在Mysql的重复消费问题

背景 最近项目中使用Flink消费kafka消息,并将消费的消息存储到mysql中,看似一个很简单的需求,在网上也有很多flink消费kafka的例子,但看了一圈也没看到能解决重复消费的问题的文章,于是在flink官网中搜索此类场景的处理方式,发现官网也没有实现flink到mysql的Exactly-Once例子,但是官网却有类似的例子来解决端到端的仅一...

Spring配置文件中<bean>标签的scope属性

转自:https://fj-sh-chz.iteye.com/blog/1775149 singleton  (默认属性)  Spring将Bean放入Spring IOC容器的缓存池中,并将Bean引用返回给调用者,spring IOC继续对这些Bean进行后续的生命管理。BeanFactory只管理一个共享的实例。所有对这个特定bean的实例请求,都导...

deb包的2种安装安装方法

一、cydia重启自动安装:用ifunbox进入//var/root/Media/Cydia/AutoInstallCydia/AutoInstall 需要分别单独建立,注意大小写。然后把你要安装的deb 拖入此目录,重启两次机器进行安装。 二、iFile安装:把deb包用ifunbox传到//var/mobile/Documents下。打开iFile软件...

C#中的Session

一: 网站开发中,为了保存用户信息我们就会用到session。 Session具有以下特点:(1)Session中的数据保存在服务器端;(2)Session中可以保存任意类型的数据;(2)Session默认的生命周期是20分钟,可以手动设置更长或更短的时间。 我们在aspx页面中的调用一般只需要这么写:<%=session["key"]=value...

在ASP.NET项目中使用XPO的最佳准则

学习XPO有一段时间了,也用它陆续做过几个项目。遇到过问题走过弯路,这里把DevExpress知识库的几篇文章的内容做了摘录和整理,并且加上了一些自己的注释,方便自己日后备忘也方便其他的朋友。 1. Always define a constructor with a Session parameter in your persistent objec...