[ https://issues.apache.org/jira/browse/BEAM-775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935726#comment-15935726 ]
Aviem Zur commented on BEAM-775: -------------------------------- As [~aljoscha] mentioned we are adding this assertion to Flink runner as well, and it has surfaced bugs which were silenced by the fact that the tests passed even though no {{PAssert}} assertions actually happened - https://github.com/apache/beam/pull/2263 All runners should add such an assertion as well, as they might also have silent bugs. There is a ticket to change to doing this assertion in the {{TestPipeline}} side of things so that runner writers won't have to know to do this: https://issues.apache.org/jira/browse/BEAM-1763 In any case, once all runners support metrics this can be done using metrics. Until then the only way to do this is with aggregators. > Remove Aggregators from the Java SDK > ------------------------------------ > > Key: BEAM-775 > URL: https://issues.apache.org/jira/browse/BEAM-775 > Project: Beam > Issue Type: Sub-task > Components: sdk-java-core > Reporter: Ben Chambers > Assignee: Pablo Estrada > Labels: backward-incompatible > Fix For: First stable release > > -- This message was sent by Atlassian JIRA (v6.3.15#6346)