Flink 原理架构总结

1、流式任务执行过程 1.任务并行      按照本身的理解，一个流程以下图所示，除非经历shuffle过程，不然流程并行度将由source的并行度决定，好比kafka分区数目，shuffle以后的并行度，可能会改变，Operator子任务(Task)彼此独立，而且能够在不一样的线程中执行，而且可能在不一样的机器或容器上执行。java 2.OperatorChain     原理同Spark 的S

>>阅读原文<<