[ 
https://issues.apache.org/jira/browse/BEAM-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935127#comment-15935127
 ] 

Kenneth Knowles commented on BEAM-1765:
---------------------------------------

1. {{ReduceFnRunner}} should be ported to metrics ASAP.
2. The use in {{PAssert}} has a couple of purposes which I am OK to give up. 
Mostly it makes sure _something_ ran. Since {{TestPipeline}} ensures that the 
pipeline runs, either {{PAssert}} or {{TestSparkRunner}} would have to have a 
catastrophic bug, I think. And {{PAssert}} is now much more clear. So we don't 
need to check that for every assertion.

> Remove Aggregators from Spark runner
> ------------------------------------
>
>                 Key: BEAM-1765
>                 URL: https://issues.apache.org/jira/browse/BEAM-1765
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-spark
>            Reporter: Pablo Estrada
>            Assignee: Amit Sela
>
> I have started removing aggregators from the Java SDK, but runners use them 
> in different ways that I can't figure out well. This is to track the 
> independent effort in Spark.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to