wollowizard commented on issue #41108: URL: https://github.com/apache/beam/issues/41108#issuecomment-6774948234
hello @parveensania here the job id : `2026-11-07_05_48_49-9397773842971649284` . For completeness, since this seemed a runner problem, I reported this as a support case and got a reply confirming that this is a bug, and I understand it's in the beam library. _Due to a flow-control issue in the Beam 2.77.0 DirectPath client, the worker can request work items faster than its local queue admits them, leaving incoming items buffered in the gRPC stream for 25–35+ seconds. While buffered in the stream, those items are neither executing on the worker (which explains the low CPU and near-zero state reads) nor receiving worker heartbeats. Once 30 seconds pass, their leases expire on the backend, triggering the retry burst._ I hope this is useful. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
