在`flink01`節點啟動`socket`服務
```shell
nc -lk 8888 # yum install -y nc # 安裝nc
```
打開網址[http://flink01:8081/#/submit](http://flink01:8081/#/submit)
設置參數
```
--hostname flink01 --port 8888
```
提交運行
進入[http://flink01:8081/#/taskmanagers](http://flink01:8081/#/taskmanagers)
進入`stdout`中進行查看結果
---
- Flink簡介
- flink搭建standalone模式與測試
- flink提交任務(界面方式)
- Flink項目初始化
- Java版WordCount(匿名類)
- Java版WordCount(lambda)
- Scala版WordCount
- Java版WordCount[批處理]
- Scala版WordCount[批處理]
- 流處理非并行的Source
- 流處理可并行的Source
- kafka的Source
- Flink算子(Map,FlatMap,Filter)
- Flink算子KeyBy
- Flink算子Reduce和Max與Min
- addSink自定義Sink
- startNewChain和disableChaining
- 資源槽slotSharingGroup
- 計數窗口
- 滾動窗口
- 滑動窗口
- Session窗口
- 按照EventTime作為標準