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 目錄，執(zhí)行./start-cluster.sh

6.訪問 localhost:8081

image.png

word count實戰(zhàn)

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

mvn clean install -Dmaven.test.skip

2.將1產(chǎn)生的 jar包上傳

image.png

3.提交任務，執(zhí)行

image.png
最后編輯于 ：
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容