在 Ubuntu 上搭建 Flink 運行環境需要以下幾個步驟:
Flink 依賴于 Java 環境運行,因此首先需要安裝 JDK。可以使用以下命令來安裝 OpenJDK 8:
sudo apt-get update
sudo apt-get install openjdk-8-jdk
從 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
在 Flink 解壓后的目錄中,可以根據需要修改配置文件。主要的配置文件有兩個:conf/flink-conf.yaml
和 conf/masters
。
在 conf/flink-conf.yaml
中,可以設置 Flink 的運行參數,例如 jobmanager 的內存大小、taskmanager 的內存大小等。
在 conf/masters
文件中,指定 JobManager 的地址。如果只在單臺機器上運行 Flink,這里可以寫 localhost
。
在 Flink 解壓后的目錄中,可以使用以下命令啟動 Flink:
./bin/start-cluster.sh
這將啟動 JobManager 和 TaskManager。你可以通過訪問 Web UI(默認地址為 http://localhost:8081)來查看 Flink 集群的狀態。
可以使用以下命令提交 Flink 作業:
./bin/flink run -c com.example.MyJob myjob.jar
其中 -c
參數指定了作業的主類名,myjob.jar
是包含作業代碼的 JAR 文件。
至此,你已經成功搭建了 Flink 運行環境。接下來就可以開始編寫和運行 Flink 作業了。