Flink中的角色包括JobManager和TaskManager。启动Flink的角色需要启动Flink集群,具体步骤如下:

  1. 下载Flink二进制包并解压缩。

  2. 启动Flink集群,使用以下命令启动JobManager:

    ./bin/start-cluster.sh
    
  3. 启动TaskManager,使用以下命令启动TaskManager:

    ./bin/taskmanager.sh start
    
  4. 可以通过Flink Web UI查看Flink集群的状态和监控信息。在浏览器中输入以下地址:

    http://localhost:8081
    

    其中,localhost为运行Flink集群的主机名或IP地址,8081为Flink Web UI的端口号。

  5. 在Flink集群中运行应用程序,使用以下命令提交应用程序:

    ./bin/flink run -c com.example.MyApplication ./path/to/MyApplication.jar
    

    其中,com.example.MyApplication为应用程序的入口类,./path/to/MyApplication.jar为应用程序的JAR包路径。

Flink集群启动指南:如何打开JobManager和TaskManager

原文地址: https://www.cveoy.top/t/topic/oSZJ 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录