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

Posted to issues@beam.apache.org by "Thomas Weise (JIRA)" <ji...@apache.org> on 2019/04/21 16:46:00 UTC

[jira] [Created] (BEAM-7127) Timer parameter not supported in timer callback

Thomas Weise created BEAM-7127:
----------------------------------

             Summary: Timer parameter not supported in timer callback
                 Key: BEAM-7127
                 URL: https://issues.apache.org/jira/browse/BEAM-7127
             Project: Beam
          Issue Type: Bug
          Components: sdk-py-harness
    Affects Versions: 2.12.0
            Reporter: Thomas Weise


Referencing the timer in its on_timer callback produces a recursive pickle error.  
{code:java}
@userstate.on_timer(timer_spec)
def process_timer(self, timer_1=beam.DoFn.TimerParam(timer_spec)):
{code}
Unit test: [https://github.com/apache/beam/blob/cbe4dfbdbe5d0da5152568853ee5e17334dd1b54/sdks/python/apache_beam/transforms/userstate_test.py#L67] 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)