Hi,
I am using below restart strategy
// Retry always
env.setRestartStrategy(RestartStrategies.failureRateRestart(
Integer.MAX_VALUE, // max failures per unit
Time.of(20, TimeUnit.MINUTES), //time interval for measuring failure rate
Time.of(10, TimeUnit.MINUTES) // delay
))
But I am facing OutOfMemory issue.
On Wed, Dec 27, 2017 at 1:23 PM, Ufuk Celebi <u...@apache.org> wrote:
> Hey Shivam,
>
> check this out:
> https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/restart_
> strategies.html
>
> Does it answer your questions?
>
> – Ufuk
>
> On Tue, Dec 26, 2017 at 9:30 AM, Shivam Sharma <28shivamsha...@gmail.com>
> wrote:
> > I am submitting my Flink Job on Yarn(Amazon EMR)
> >
> > On Tue, Dec 26, 2017 at 1:59 PM, Shivam Sharma <28shivamsha...@gmail.com
> >
> > wrote:
> >
> >> Hi,
> >>
> >> My Flink job fails due to external activity like when Kafka goes down. I
> >> want to restart my Flink job after certain time interval.
> >>
> >> *I need to know best practices in this. How to restart Flink job
> >> automatically.*
> >>
> >> Thanks
> >>
> >> --
> >> Shivam Sharma
> >> Data Engineer @ Goibibo
> >> Indian Institute Of Information Technology, Design and Manufacturing
> >> Jabalpur
> >> Mobile No- (+91) 8882114744
> >> Email:- 28shivamsha...@gmail.com
> >> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> >> <https://www.linkedin.com/in/28shivamsharma>*
> >>
> >
> >
> >
> > --
> > Shivam Sharma
> > Data Engineer @ Goibibo
> > Indian Institute Of Information Technology, Design and Manufacturing
> > Jabalpur
> > Mobile No- (+91) 8882114744
> > Email:- 28shivamsha...@gmail.com
> > LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> > <https://www.linkedin.com/in/28shivamsharma>*
>
--
Shivam Sharma
Data Engineer @ Goibibo
Indian Institute Of Information Technology, Design and Manufacturing
Jabalpur
Mobile No- (+91) 8882114744
Email:- 28shivamsha...@gmail.com
LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
<https://www.linkedin.com/in/28shivamsharma>*
