Thanks for the reply Till. Resubmitting the job is an option.
I was wondering if there's any way that Flink could be configured to detect
issues like a memory issue and rescale without me submitting the job again.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.co
Hi Anil,
you can use `flink modify -p ` to scale a running
job under JOB_ID to the NEW_PARALLELISM.
Cheers,
Till
On Mon, Jul 9, 2018 at 9:45 AM Anil wrote:
> This is regarding dynamic rescaling in Flink 1.5
>
> I am using Yarn for running Flink jobs. I start these jobs with a static
> resourc
This is regarding dynamic rescaling in Flink 1.5
I am using Yarn for running Flink jobs. I start these jobs with a static
resource. Is there any option to scale out these job by itself in specific
conditions like if there's a memory issues.
In Flink 1.5 release notes -
Applications can be rescal
This is regarding dynamic rescaling in Flink 1.5
I am using Yarn for running Flink jobs. I start these jobs with a static
resource. Is there any option to scale out these job by itself in specific
conditions like if there's a memory issues.
In Flink 1.5 release notes -
Applications can be rescal
