some confuse for data exchange of parallel operator

Posted by tangkailin on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/some-confuse-for-data-exchange-of-parallel-operator-tp29175.html

Hello,

       I don’t know how parallel operator exchange data in flink. for example, I define a map in a operator with n (n > 1) parallelism for counting. Can this map record all data? Or this map only record data from one parallelism of upstream operator?

 

Thanks,

Kylin