pyflink的内部体系结构

Question

我引用了下面显示的文章，该文章指示Pyflink在Python解释器和JVM上的工作方式。

我无法弄清楚他们是否在几个过程中执行工作，等等...

所以我留下了我的解释他们的内部系统在这里，想请您纠正它。

我的解释：

1. 用户在Python中写入程序。
2. Python解释器制作一个过程（过程1），该过程是控制与JVM Gatewayserver（过程2）的连接的过程。
3. 进程1将使流媒体形成工作图，并将其通过套接字提交给JVM Gateway Server。 它也用于传递输入数据并接收输出数据。
4. 下一步，JobManager（Process 3）计划实际执行并分配足够的任务插槽。（进程4），这是一个执行图，该执行图已对其进行平行并准备执行。
5. 有几个需要致电Python，因为某些操作员使用UserDefined Function或Lambdafunc等。在这种情况下，操作员（例如地图，flatmap）（进程4）将状态和一些相关信息提交给Python Process（过程5），该进程是为执行UDF或Lambda等... JVM的操作员。

Answer 1

我建议您观看 pyflink：使用Python Language 在上一个Flink Forward Conference中构建Flink应用程序以获取答案。您可以在