jjzjj

NoRestartBackoffTimeStrategy

全部标签

flink 1.14.3集群jar部署Recovery is suppressed by NoRestartBackoffTimeStrategy

flink程序在开发环境已经运行成功的情况下,部署到独立的flink集群(start-cluster)中,可能遇到不能正常运行的情况。1.org.apache.flink.runtime.JobException:RecoveryissuppressedbyNoRestartBackoffTimeStrategy没有指定重启策略,在本地部署时,不需要指定重启策略。可以通过下面的代码指定重启策略env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3,//尝试重启的次数Time.of(10,TimeUnit.SECONDS)//间隔

org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy

1.提交flink任务时报错:Causedby:org.apache.flink.runtime.client.JobExecutionException:Jobexecutionfailed.atorg.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)atorg.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java: