flink ExcutionVertex

Flink ExecutionVertex 是 Flink 中非常重要的一个概念，它代表了 Flink 作业执行中的计算节点。每个 ExecutionVertex 对应一个并行算子的一个并行实例，也就是说，如果一个算子被设置了并行度为 4，那么就会有 4 个 ExecutionVertex 实例在集群中执行该算子的计算任务。

在 Flink 作业执行期间，每个 ExecutionVertex 会被分配到一个 Task Slot 中，Task Slot 是 Flink 集群中的计算资源的抽象，它可以是一个 TaskManager 中的一个线程或者是一个容器中的一个进程。每个 ExecutionVertex 会接收来自上游 ExecutionVertex 的数据，并进行计算处理，然后将处理结果发送给下游 ExecutionVertex。

Flink ExecutionVertex 之间通过数据流连接起来，形成了 Flink 作业的数据流图。在 Flink 作业执行期间，Flink 会动态地调整 ExecutionVertex 的数量和位置，以最大化作业的性能和资源利用率。如果某个 ExecutionVertex 发生了错误，Flink 会将该 ExecutionVertex 重新启动，并将它之前接收到的数据重新发送给它。

总之，Flink ExecutionVertex 是 Flink 中非常重要的一个概念，它负责处理作业中的计算任务，并通过数据流连接起来，实现整个 Flink 作业的数据流处理。