Hi, I am trying to understand how subtask distribution works in Flink. Let's assume a setup of a Flink cluster with a fixed number of TaskManagers in a kubernetes cluster.
Let's say I have a flink job with all the operators having the same parallelism and with the same Slot sharing group. The operator parallelism is computed as the number of task managers multiplied by number of task slots per TM. 1. Does this mean that each task slot will contain an entire pipeline in the job? 2. Upon a TM pod failure and after K8s brings back the TM pod, would flink assign the same subtasks back to restarted TM again? Or will they be distributed to different TaskManagers? It would be great if someone can answer this question. Thanks.
