在Ubuntu上安装Apache Flink,您需要按照以下步骤操作:
更新系统包和安装Java开发工具包(JDK):sudo apt-get updatesudo apt-get install openjdk-11-jdk下载并解压Flink:首先,访问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将Flink目录移动到适当的位置:sudo mv flink-1.14.0 /opt/flink为Flink创建一个专用用户:sudo useradd flinksudo chown -R flink:flink /opt/flink配置环境变量:编辑~/.bashrc文件,添加以下行:
export FLINK_HOME=/opt/flinkexport PATH=$PATH:$FLINK_HOME/bin保存并关闭文件。然后运行以下命令使更改生效:
source ~/.bashrc测试Flink安装:运行以下命令以确保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构建和运行实时流处理和批处理应用程序了。


