flink中datastream和dataset各自print()的异同
生活随笔
收集整理的這篇文章主要介紹了
flink中datastream和dataset各自print()的异同
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
根據[1]
?
| ? | 負責輸出的進程 | 默認能打印到提交任務的終端嗎? | print()結果 輸出位置 | 在WEB UI查看位置 |
| 批處理(DataSet) | Job Manager | 能 | Master節點的 提交任務的終端 | Job Manager中的Stdout |
| 流處理(DataStream) | Task Manager | 不能 | Slave節點的 $FLINK_HOME/log/*.out | Task?Managers中的Stdout |
下面是Flink的Web UI
注意看左側有兩個manager
請注意配合上面的表格來理解
?
Reference:
[1]Why doesn't the Flink SocketTextStreamWordCount work?
總結
以上是生活随笔為你收集整理的flink中datastream和dataset各自print()的异同的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: intellij连接真实的flink集群
- 下一篇: Error while retrievi