ppawel commented on issue #35126: URL: https://github.com/apache/beam/issues/35126#issuecomment-2967412417
I think it's related because the worker shutdown/restart only happens inside pipelines/jobs that have this original exception in them (the NPE). This NPE also appears in the logs immediately after new worker is started, then after ~1 hour, new worker is replacing the "unhealthy" one and then the NPE happens etc. So I assume that this NPE prevents the runtime to check healthiness properly and that's why it kills the worker. -- 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
