blink 初使用

blink开源，目前在https://github.com/apache/flink/tree/blink

使用步骤：

1.git clone https://github.com/apache/flink.git

2.切到blink 分支

3.修改pom，注释掉

    <module>flink-tests</module>
    <module>flink-yarn-tests</module>
    <module>flink-fs-tests</module>
    <module>flink-end-to-end-tests</module>

4. mvn clean install -Dmaven.test.skip -Dcheckstyle.skip -Dlicense.skip=true -Drat.ignoreErrors=true

如果以前编译过则先保存提交新建的文件 然后
git clean -f -d
git clean -f -X
git clean -f -x
清理不必要的文件

5.进入build-target/bin 目录，执行./start-cluster.sh

6.访问 localhost:8081

image.png

word count实战

1.进入flink-examples/flink-examples-streaming

mvn clean install -Dmaven.test.skip

2.将1产生的 jar包上传

image.png

3.提交任务，执行

image.png