How Flink's async-io-api parameters work?

2021-05-01 Thread Diwakar Jha
Hello, I'm trying to solve a problem using async-io-api. I'm running a flinkjob which has a sleep time of 120sec during restart. After every deployment i see around 10K file load time out. I suspect it is because of the TimeOut parameter being *30 sec*. I played with that number and found out that

Re: Best practice for packaging and deploying Flink jobs on K8S

2021-05-01 Thread Dian Fu
Hi Sumeet, FYI: the documentation about the CLI options of PyFlink has already been updated [1]. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/cli.html#submitting-pyflink-jobs Regards, Dian On Thu, Apr 29, 2021 at 4:46 PM Dian Fu wrote: > Hi Sumeet, > > For the