公司有部分项目是基于 storm 开发的，目前想进行改造，计划用 flink。
初步看了下代码，发现 storm 中实现都是通过 multi-lang 方式各种调用 shell、python 实现。这些shell和python主要通过storm提供的一个 storm.py 基础包实现和 父进程 的通信（基于stdin和stdout貌似）。 想问问，这种如何改造呢？ 首先是大方向上，（1）连同python、shell部分一起改造。（2）保留python、shell部分，基于flink实现一套类似机制。 （1）和（2）目前看起来都会很复杂。 有没有小伙伴做过类似事情呢？
