mxm commented on issue #11492:
URL: https://github.com/apache/beam/pull/11492#issuecomment-618326851


   Thanks for your help @boyuanzz. Unfortunately, I wasn't able to let the test 
pass. I'm running into a problem with setting a timer from a timer callback. 
   
   ```
   apache_beam/runners/portability/fn_api_runner/fn_runner.py:851:
   _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ _ _ _ _ _ _ _ _ _ _
   
   self = <apache_beam.runners.portability.fn_api_runner.execution.ListBuffer 
object at 0x1180dbed0>
   element = 
b'\x02k1\x00\x00\x00\x00\x01\x00\x80\x00\x00\x00\x00\x0fB@\x80\x00\x00\x00\x00\x00N
 
\x0f\x02k2\x00\x00\x00\x00\x01\x00\x80\x00\x00\x00\x00\x0fB@\x80\x00\x00\x00\x00\x03\r@\x0f'
   
       def append(self, element):
         # type: (bytes) -> None
         if self.cleared:
   >       raise RuntimeError('Trying to append to a cleared ListBuffer.')
   E       RuntimeError: Trying to append to a cleared ListBuffer.
   
   apache_beam/runners/portability/fn_api_runner/execution.py:96: RuntimeError
   ====================================================================== 1 
failed, 3 warnings in 2.43 seconds 
=======================================================================
   ```
   
   I've tried resetting the timer buffer but that led to the test getting 
stuck. I don't have the time to continue to work on this. If you or someone 
else could take this over I'd appreciate it. It would be good to fix this for 
the release.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to