[
https://issues.apache.org/jira/browse/BEAM-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1629:
----------------------------
Description: Today aggregators and metrics accumulators are instantiated
after pipeline is traversed, and so, if code that runs on driver accesses these
singletons but is not part of a closure a {{NullPointerException}} is thrown.
(was: Today aggregators and metrics accumulators are instantiated after
pipeline is traversed, and so, if transform translations access these
singletons in code which runs on the driver, but is not part of a closure, a
{{NullPointerException}} is thrown.)
> Make metrics/aggregators accumulators available on driver
> ---------------------------------------------------------
>
> Key: BEAM-1629
> URL: https://issues.apache.org/jira/browse/BEAM-1629
> Project: Beam
> Issue Type: Bug
> Components: runner-spark
> Reporter: Aviem Zur
> Assignee: Aviem Zur
>
> Today aggregators and metrics accumulators are instantiated after pipeline is
> traversed, and so, if code that runs on driver accesses these singletons but
> is not part of a closure a {{NullPointerException}} is thrown.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
