flink常用命令


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.xxx.xxxx.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.code.helper_workflow.HelperWorkFlowStreaming -yid application_1625727533919_9494 /var/lib/hadoop-hdfs/flink/jars/BSS-ONSS-Flink-1.0-SNAPSHOT.jar

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM