Re: Failure Restart Strategy leads to error

2022-01-26 Thread Siddhesh Kalgaonkar
tion to kafka related configurations. > > > Best > Yun Tang > ---------- > *From:* Siddhesh Kalgaonkar > *Sent:* Wednesday, January 26, 2022 3:17 > *To:* user > *Subject:* Failure Restart Strategy leads to error > > I have Flink Kafka Consumer i

Re: Failure Restart Strategy leads to error

2022-01-26 Thread Yun Tang
: Siddhesh Kalgaonkar Sent: Wednesday, January 26, 2022 3:17 To: user Subject: Failure Restart Strategy leads to error I have Flink Kafka Consumer in place which works fine until I add the below lines: env.setRestartStrategy(RestartStrategies.failureRateRestart( 3, // max failures per unit

Failure Restart Strategy leads to error

2022-01-25 Thread Siddhesh Kalgaonkar
I have Flink Kafka Consumer in place which works fine until I add the below lines: env.setRestartStrategy(RestartStrategies.failureRateRestart( 3, *// max failures per unit* Time.of(5, TimeUnit.MINUTES), *//time interval for measuring failure rate* Time.of(10, TimeUnit.SECONDS) *// delay*)) It