Skip to main content

Flink

WebUI

JobManager网页默认端口8081,参数配置如下:

rest.port: 8081

命令

官方文档

run

提交Flink作业。部分参数说明如下:

参数说明
-c,--class <classname>指定带有main函数的class入口类
-d,--detached分离模式
-t,--target <arg>For the "run" action: "remote", "local", "kubernetes-session", "yarn-per-job" (deprecated), "yarn-session".For "run-application" action: "kubernetes-application","yarn-application"
-D <property=value>指定flink运行参数

使用示例:

flink run -e local $FLINK_HOME/examples/streaming/WordCount.jar

run-application

flink run-application -d -t yarn-application $FLINK_HOME/examples/streaming/WordCount.jar

info

list

stop

cancel

savepoint

checkpoint