If the N reduce tasks of one job are executed on M node, in shuffle of map
phase, can I do partition per node rather than per reduce tasks?

Does yarn support custom shuffler plugin to implement the above idea?

-- 
*Sincerely,*
*Zhaojie*
*
*

Reply via email to