[ https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15939312#comment-15939312 ]
Eugene Kirpichov commented on BEAM-1148: ---------------------------------------- One option is to let PAssert output the failures (or success) to a file in the job's temp directory. Another option: in case of success the pipeline should simply terminate successfully (even if it's being run using "streaming" mode, by a runner that has a concept of modes - according to the termination semantics); so it only remains to make sure that in case of failure the whole pipeline fails rather than hangs. There should be an API to fail a pipeline, or to watch failures within it. The treatment of failures, e.g. by Dataflow batch vs. streaming runners, is inconsistent. That's probably topic for a separate JIRA. > Port PAssert away from Aggregators > ---------------------------------- > > Key: BEAM-1148 > URL: https://issues.apache.org/jira/browse/BEAM-1148 > Project: Beam > Issue Type: New Feature > Components: sdk-java-core > Reporter: Kenneth Knowles > > One step in the removal of Aggregators (in favor of Metrics) is to remove our > reliance on them for PAssert checking. -- This message was sent by Atlassian JIRA (v6.3.15#6346)