本地執行時設定

  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