本地运行时设置
-
确保你有 java 6 或更高版本并且设置了
JAVA_HOME
环境变量。 -
在这里下载最新的 flink 二进制文件 :
wget flink-XXXX.tar.gz
如果你不打算使用 Hadoop,请选择 hadoop 1 版本。另外,请注意你下载的 scala 版本,以便在程序中添加正确的 maven 依赖项。
-
开始 flink:
tar xzvf flink-XXXX.tar.gz ./flink/bin/start-local.sh
Flink 已配置为在本地运行。要确保 flink 正在运行,你可以检查
flink/log/
中的日志或打开在http://localhost:8081
上运行的 flink jobManager 的界面。 -
停止 flink:
./flink/bin/stop-local.sh