AyWa opened a new pull request, #31188: URL: https://github.com/apache/beam/pull/31188
# Descriptions Previously made an attempt to solve that in https://github.com/apache/beam/pull/28068/files, but at that time, I didn't have time to follow up. I will try to contribute better to beam (especially for flink runner). In this PR, we make * `FlinkPortableClientEntryPoint` accept parameters that `JobServerDriver` can handle. * Add arguments for timeout. (We have this issue with JobManager that have low cpu assigned in k8s). -- 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]
