beam icon indicating copy to clipboard operation
beam copied to clipboard

Published 20 hours ago • verified publisher icon apache

flink portable client configurations

Open AyWa opened this issue 9 months ago • 6 comments

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).

AyWa avatar May 06 '24 14:05 AyWa