要在 Ubuntu 上部署 Flink 的 Web UI,请按照以下步骤操作:
-
安装 Java 开发工具包 (JDK):
Flink 需要 Java 运行环境。首先,请确保已安装 JDK。可以使用以下命令来安装 OpenJDK 8:
sudo apt-get update sudo apt-get install openjdk-8-jdk
安装完成后,通过运行以下命令来检查 Java 版本:
java -version
-
下载并解压 Flink 二进制文件:
从 Flink 官方网站(https://flink.apache.org/downloads.html)下载最新的 Flink 二进制文件。选择合适的 Scala 版本。然后,使用以下命令解压下载的文件:
tar xzf flink-*.tgz
-
配置 Flink:
转到解压后的 Flink 目录,并编辑
conf/flink-conf.yaml
文件。可以根据需要修改配置参数,例如 jobmanager 的内存大小、taskmanager 的内存大小等。 -
启动 Flink:
在解压后的 Flink 目录中,运行以下命令以启动 Flink:
./bin/start-cluster.sh
这将启动 Flink JobManager 和 TaskManager。
-
访问 Flink Web UI:
Flink Web UI 默认运行在 8081 端口。在浏览器中输入 http://localhost:8081 或者 http://your_server_ip:8081 以访问 Flink Web UI。
-
提交 Flink 任务:
若要提交 Flink 任务,可以使用以下命令:
./bin/flink run path/to/your/jarfile.jar
其中,
path/to/your/jarfile.jar
是 Flink 任务 JAR 文件的路径。 -
关闭 Flink:
若要关闭 Flink,可以运行以下命令:
./bin/stop-cluster.sh
现在,您已经在 Ubuntu 上部署了 Flink 的 Web UI,并可以使用它来管理和监控 Flink 任务。