je-ik commented on pull request #12551: URL: https://github.com/apache/beam/pull/12551#issuecomment-674059727
@mxm I think I figured it out. The current commit https://github.com/apache/beam/pull/12551/commits/fe75b7e01d55a0c24486b032330d26d66b57f9c2 works for my pipeline. I think the explanation is that the pipeline was not really completely stuck, only so slow, it looked like that. PriorityQueue#remove(Object) has O(N) complexity and when there is really many, many, many timers (with nearly the same output timestamp), it would cause the Pipeline to stop running. ---------------------------------------------------------------- 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]
