Flink集群启动指南:如何打开JobManager和TaskManager
Flink中的角色包括JobManager和TaskManager。启动Flink的角色需要启动Flink集群,具体步骤如下:
-
下载Flink二进制包并解压缩。
-
启动Flink集群,使用以下命令启动JobManager:
./bin/start-cluster.sh -
启动TaskManager,使用以下命令启动TaskManager:
./bin/taskmanager.sh start -
可以通过Flink Web UI查看Flink集群的状态和监控信息。在浏览器中输入以下地址:
http://localhost:8081其中,localhost为运行Flink集群的主机名或IP地址,8081为Flink Web UI的端口号。
-
在Flink集群中运行应用程序,使用以下命令提交应用程序:
./bin/flink run -c com.example.MyApplication ./path/to/MyApplication.jar其中,com.example.MyApplication为应用程序的入口类,./path/to/MyApplication.jar为应用程序的JAR包路径。
原文地址: https://www.cveoy.top/t/topic/oSZJ 著作权归作者所有。请勿转载和采集!