在Ubuntu上安裝Apache Flink,您需要按照以下步驟操作:
sudo apt-get update
sudo apt-get install openjdk-11-jdk
首先,訪問Flink官方下載頁面(https://flink.apache.org/downloads.html),然后選擇一個適合您的版本。在撰寫本文時,最新版本是1.14.0。將下載鏈接地址復制到wget命令中以下載相應的tar文件。
wget https://downloads.apache.org/flink/flink-1.14.0/flink-1.14.0-bin-scala_2.11.tgz
解壓下載的tar文件:
tar -xzf flink-1.14.0-bin-scala_2.11.tgz
sudo mv flink-1.14.0 /opt/flink
sudo useradd flink
sudo chown -R flink:flink /opt/flink
編輯~/.bashrc
文件,添加以下行:
export FLINK_HOME=/opt/flink
export PATH=$PATH:$FLINK_HOME/bin
保存并關閉文件。然后運行以下命令使更改生效:
source ~/.bashrc
運行以下命令以確保Flink正常運行:
flink run --class org.apache.flink.examples.java.wordcount.WordCount \
$FLINK_HOME/examples/batch/WordCount.jar \
--input /opt/flink/README.txt --output /tmp/wordcount_output
這將運行一個簡單的單詞計數示例,輸出結果將保存在/tmp/wordcount_output
文件中。
至此,您已成功在Ubuntu上安裝了Apache Flink。現在可以開始使用Flink構建和運行實時流處理和批處理應用程序了。