温馨提示×

Flink在Ubuntu上的运行环境如何搭建

小樊
105
2024-09-08 18:32:32
栏目: 智能运维

在 Ubuntu 上搭建 Flink 运行环境需要以下几个步骤:

  1. 安装 Java 开发环境(JDK)

Flink 依赖于 Java 环境运行,因此首先需要安装 JDK。可以使用以下命令来安装 OpenJDK 8:

sudo apt-get update
sudo apt-get install openjdk-8-jdk
  1. 下载并解压 Flink 二进制包

从 Flink 官网(https://flink.apache.org/downloads.html)下载最新版本的 Flink 二进制包,然后解压到一个目录中。例如:

wget https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz
tar -xzf flink-1.13.2-bin-scala_2.11.tgz
cd flink-1.13.2
  1. 配置 Flink

在 Flink 解压后的目录中,可以根据需要修改配置文件。主要的配置文件有两个:conf/flink-conf.yamlconf/masters

  • conf/flink-conf.yaml 中,可以设置 Flink 的运行参数,例如 jobmanager 的内存大小、taskmanager 的内存大小等。

  • conf/masters 文件中,指定 JobManager 的地址。如果只在单台机器上运行 Flink,这里可以写 localhost

  1. 启动 Flink

在 Flink 解压后的目录中,可以使用以下命令启动 Flink:

./bin/start-cluster.sh

这将启动 JobManager 和 TaskManager。你可以通过访问 Web UI(默认地址为 http://localhost:8081)来查看 Flink 集群的状态。

  1. 提交 Flink 作业

可以使用以下命令提交 Flink 作业:

./bin/flink run -c com.example.MyJob myjob.jar

其中 -c 参数指定了作业的主类名,myjob.jar 是包含作业代码的 JAR 文件。

至此,你已经成功搭建了 Flink 运行环境。接下来就可以开始编写和运行 Flink 作业了。

0