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.