Hi community!

So many keys are computed separately in each operator parallel, how does Flink 
achieve this? Let an operator instance processes 100 keys, is there 100 thread 
that are managed by the operator instance thread?

I know that 
1. an operator many have many parallel instances at the same time, 
2. each of parallel instances is responsible to a “key group”, and each key 
group is composed of many keys. 
3. Several operator parallel instances may come from the same TaskManager and 
each of them is a thread.

Reply via email to