本地运行时设置

  1. 确保你有 java 6 或更高版本并且设置了 JAVA_HOME 环境变量。

  2. 这里下载最新的 flink 二进制文件 :

    wget flink-XXXX.tar.gz
    

    如果你不打算使用 Hadoop,请选择 hadoop 1 版本。另外,请注意你下载的 scala 版本,以便在程序中添加正确的 maven 依赖项。

  3. 开始 flink:

    tar xzvf flink-XXXX.tar.gz
    ./flink/bin/start-local.sh
    

    Flink 已配置为在本地运行。要确保 flink 正在运行,你可以检查 flink/log/中的日志或打开在 http://localhost:8081 上运行的 flink jobManager 的界面。

  4. 停止 flink:

    ./flink/bin/stop-local.sh