Re: threading and distribution

2021-02-11 Thread Matthias Pohl
Hi Marco, sorry for the late reply. The documentation you found [1] is already a good start. You can define how many subtasks of an operator run in parallel using the operator's parallelism configuration [2]. Each operator's subtask will run in a separate task slot. There's the concept of slot shar

Re: threading and distribution

2021-02-05 Thread Marco Villalobos
Okay, I am following up to my question. I see information regarding the threading and distribution model on the documentation about the architecture. https://ci.apache.org/projects/flink/flink-docs-release-1.12/concepts/flink-architecture.html Next, I want to read up on what I have control over.