This Jira has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems email email@example.com
Referencing the timer in its on_timer callback produces a recursive pickle error.
def process_timer(self, timer_1=beam.DoFn.TimerParam(timer_spec)):
Unit test: https://github.com/apache/beam/blob/cbe4dfbdbe5d0da5152568853ee5e17334dd1b54/sdks/python/apache_beam/transforms/userstate_test.py#L67
Expose kv and window parameters for on_timer