目前看了下pyflink,想了解下,pyflink的任务实际运行时也是JAVA+python双环境吗。
涉及java和python交互等是吗。性能相比java直接开发的任务会有区别吗?

yidan zhao <hinobl...@gmail.com> 于2022年7月12日周二 19:27写道:
>
> 公司有部分项目是基于 storm 开发的,目前想进行改造,计划用 flink。
>
> 初步看了下代码,发现 storm 中实现都是通过 multi-lang 方式各种调用 shell、python
> 实现。这些shell和python主要通过storm提供的一个 storm.py 基础包实现和 父进程
> 的通信(基于stdin和stdout貌似)。
>
> 想问问,这种如何改造呢?
> 首先是大方向上,(1)连同python、shell部分一起改造。(2)保留python、shell部分,基于flink实现一套类似机制。
>
> (1)和(2)目前看起来都会很复杂。
>
> 有没有小伙伴做过类似事情呢?

回复