flink算子动态编排 - 技术调研历程

flink算子动态编排 - 技术调研历程

# 1. 首先，先展示一张常规编写算子计算流程的示意图

 

# 2. 如上图所示，常规编写算子，相当于死代码，

我们不能够在服务运行的时候，动态的去变更算子流程，

不过这个地方受限于flink生成的计算流图，当服务启动至运行的过程中，flink会将算子的计算流图生成好，不能够进行动态的变更。

当然下面的技术调研，也没有突破这个瓶颈，只是可以在不停止服务，不影响原有算子编排任务前提下，创建新的算子编排任务