[
https://issues.apache.org/jira/browse/BEAM-1304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stas Levin resolved BEAM-1304.
------------------------------
Resolution: Fixed
Fix Version/s: 0.6.0
> NPE if trying to get value of Aggregator that does not exist.
> -------------------------------------------------------------
>
> Key: BEAM-1304
> URL: https://issues.apache.org/jira/browse/BEAM-1304
> Project: Beam
> Issue Type: Bug
> Components: runner-spark
> Reporter: Amit Sela
> Assignee: Stas Levin
> Fix For: 0.6.0
>
>
> Querying a specific aggregator value in {{SparkPipelineResult}} could throw
> NPE if the get Aggregator name doesn't exist.
> This is the root of the problem:
> https://github.com/apache/beam/blob/master/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java#L74
> {{Map#get()}} will return {{null}}.
> We could either return {{null}}, though this could simply propagate the
> problem upstream, or use {{Optional}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
