You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Aviem Zur (JIRA)" <ji...@apache.org> on 2017/03/06 19:02:32 UTC

[jira] [Updated] (BEAM-1629) Make metrics/aggregators accumulators available on driver

     [ 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)