Commit 78c2d23
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 #45601 parent 2317a70 commit 78c2d23
File tree
3 files changed
+270
-37
lines changed- src/mango
- src
- test
3 files changed
+270
-37
lines changed
0 commit comments