下載&&安裝
Flink 可以運行在 Linux、Mac OS X 和 Windows 上。本地模式的安裝唯一需要的只是 Java 1.7.x或更高版本。接下來的指南假定是類Unix環(huán)境，Windows用戶請移步到Flink on Windows。
安裝Java 7.x(or higher)
java -version
#If you have Java 8, the output will look something like this:
java version "1.8.0_111"
Java(TM) SE Runtime Environment (build 1.8.0_111-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.111-b14, mixed mode)
下載flink程序，下載方式移步到下載頁。
如果只是跑本地模式，那么我們可以用任何一個版本。
比如：我們選用：flink-1.2.0-bin-hadoop2-scala_2.10.tgz
wget http://archive.apache.org/dist/flink/flink-1.2.0/flink-1.2.0-bin-hadoop2-scala_2.10.tgz
cd ~/Downloads # Go to download directory
tar xzf flink-*.tgz # Unpack the downloaded archive
cd flink-1.2.0
Local 模式
啟動
./bin/start-local.sh
打開http://localhost:8081 可以看到一個flink運行信息的界面。如果能打開，則說明啟動ok。
當然，我們也可以通過日志來確定是不是啟動ok了。
$ tail log/flink-*-jobmanager-*.log
INFO ... - Starting JobManager
INFO ... - Starting JobManager web frontend
INFO ... - Web frontend listening at 127.0.0.1:8081
INFO ... - Registered TaskManager at 127.0.0.1 (akka://flink/user/taskmanager)
如果你遇到端口被占用的情況，打開conf/flink-conf.yaml。
找到如下代碼改成其他端口即可。
jobmanager.web.port: 8081
運行demo
batch
./bin/flink run examples/batch/WordCount.jar
streaming
./bin/flink run examples/streaming/WordCount.jar --output ./wc.txt
打開wc.txt就可以看到執(zhí)行結果了。
當然，我們也可以指定輸入輸出，比如
./bin/flink run examples/streaming/WordCount.jar --input input.txt --output wc.txt
ps: wordcount源碼：java on github.
文章參考
