lostluck commented on issue #32115: URL: https://github.com/apache/beam/issues/32115#issuecomment-2276556378
It's looking like I'm mis-handling the timer format! From the Data stream, the Elements_Timers.Timers field is an encoded "logical stream" of timers. That is there can be more than one. I'm treating that as a single timer, when there could in fact be more than one. Need to add a decoding loop, but should help resolve the whole set. This is in test_pardo_timers (without the clearing). ----- The clear test has perplexing behavior though, as it looks like timers are simply never received. That can't be right. -- 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. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
