Skip to content

Commit fa05850

Browse files
committed
mango: rolling execution statistics
In case of map-reduce views, the arrival of the `complete` message is not guaranteed for the view callback (at the shard) when a `stop` is issued during the aggregation (at the coordinator). Due to that, internally collected shard-level statistics may not be fed back to the coordinator which can cause data loss hence inaccuracy in the overall execution statistics. Address this issue by switching to a "rolling" model where row-level statistics are immediately streamed back to the coordinator. Support mixed-version cluster upgrades by activating this model only if requested through the map-reduce arguments and the given shard supports that. Fixes #4560
1 parent 2501fe6 commit fa05850

File tree

3 files changed

+271
-37
lines changed

3 files changed

+271
-37
lines changed

0 commit comments

Comments
 (0)