clone官方1.6.2版本flink，成功编译。（一般PC还真跑不动，我是用服务器编译的）
编译完后，略微修改了一下启动脚本后，成功跑起来。
sh bin/start-cluster.sh
红色部分是我改过的地方：
vim start-cluster.sh
bin=`dirname "$0"`
bin=`cd "$bin"; pwd`
FLINK_BIN_DIR=$bin
cd $bin
. config.sh
启动成功后就可以看界面，也可以运行job了。
flink的源码大部分是java写的，少部分是scala写的（运行时模块）
入口类（启动后两个进程，两个入口类）：
org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint
org.apache.flink.runtime.taskexecutor.TaskManagerRunner
再介绍一下基本概念Stream和DataSet，前者用于流处理，后者用于批处理。