spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Herman van Hövell (Jira) <>
Subject [jira] [Commented] (SPARK-30108) Add robust accumulator for observable metrics
Date Mon, 09 Dec 2019 09:00:05 GMT


Herman van Hövell commented on SPARK-30108:

[~Ankitraj] Great to hear! Here are some pointers, the goal of this ticket to make the current
AggregatingAccumulator to only add the result of a partition once. For this we need to do
a couple of things:
 - We need to add some tracking mechanism to the AggregatingAccumulator that keeps track of
the partitions that have been processed. A (compressible) bit map should be enough.
 - We need a way to tell the accumulator's merge method which partition it is processing.
One way of doing this would be making a small change in the way the DAGScheduler interacts
with the accumulator, and also pass Task/Partition info on calling update. A less intrusive
way of doing this would be to pass back partition info with the to-be-merged accumulator.

> Add robust accumulator for observable metrics
> ---------------------------------------------
>                 Key: SPARK-30108
>                 URL:
>             Project: Spark
>          Issue Type: New Feature
>          Components: SQL
>    Affects Versions: 3.0.0
>            Reporter: Herman van Hövell
>            Priority: Major

This message was sent by Atlassian Jira

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message