【Flink】Flink 運行架構及 Flink 流處理 API

一、Flink 的運行時組件 Flink 運行時架構主要包括四個不一樣的組件，它們會在運行流處理應用程序時協同工做：做業管理器（JobManager）、資源管理器（ResourceManager）、任務管理器（TaskManager），以及分發器（Dispatcher）。由於 Flink 是用 Java 和 Scala 實現的，因此全部組件都會運行在Java 虛擬機上。每一個組件的職責以下： we

>>阅读原文<<