Details
-
Sub-task
-
Status: In Progress
-
Major
-
Resolution: Unresolved
-
3.0.0-alpha1
-
None
-
None
Description
MapTask needs to start node-level aggregation against local outputs at the end stage of MapTask after calling getAggregationTargets().
This feature is implemented with Merger and CombinerRunner.