Flink運行架構及相關命令
最近學習了Flink，整理了一些關于flink函式框架運行和相關算子的運算方法，
flink阿里17年開始開源blink，里面融合的部分flink功能，比如flink SQL
Flink專案的理念是：“Apache Flink是為分布式、高性能、隨時可用以及準確的流處理應用程式打造的開源的有狀態的流處理框架”，
? Apache Flink是一個框架和分布式處理引擎，用于對無界和有界資料流進行有狀態計算 ，Flink被設計在所有常見的集群環境中運行，以記憶體執行速度和任意規模來執行計算，
狀態相當于歷史資料，
flink可以相當于三部分來學習，
相關運行命令
| 指令 | 功能 |
|---|---|
| Flink | 提交任務引數 |
| flink | 執行任務腳本 |
| run | 執行作業（ApplicationMode模式除外） |
| run-application | ApplicationMode模式的執行作業 |
| -d | 后臺運行 |
| -m | 指定JobManager |
| -c | 指定全類名 |
| -D | 如果要指定其它配置，可以跟在-D 后面 格式：（-D引數名=引數值） |
| -t | 指定以yarn的什么模式，yarn-per-job yarn-session yarn-application |
| -p | 提交任務時指定并行度 |
運行架構
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/356936.html
標籤：其他