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