Flink yarn session exception

2020-07-16 Thread Rainie Li
大佬们好,我是flink新手,正在用flink 1.9.1 Flink APP cannot run, APP log error, 想求教一下会是什么原因造成的,多谢🙏 2020-06-16 17:06:21,921 WARN org.apache.flink.client.cli.CliFrontend - Could not load CLI class org.apache.flink.yarn.cli.FlinkYarnSessionCli. java.lang.NoClassDefFoundError: org/apache/hadoop/y

Re: Flink yarn session exception

2020-07-16 Thread Rainie Li
docs-release-1.11/ops/deployment/hadoop.html > > > Best, > Paul Lam > > > 2020年7月16日 15:46,Rainie Li 写道: > > > > 大佬们好,我是flink新手,正在用flink 1.9.1 > > Flink APP cannot run, APP log error, 想求教一下会是什么原因造成的,多谢🙏 > > > > 2020-06-16 17:06:21,921 WARN org.apa

Re: Flink yarn session exception

2020-07-16 Thread Rainie Li
好搭,谢谢! On Thu, Jul 16, 2020 at 5:32 PM 忝忝向仧 <153488...@qq.com> wrote: > 你可以看看lib里面的包跟官网的要求是不是一样的 > > > > 发自我的iPhone > > > -- Original ------ > From: Rainie Li Date: Fri,Jul 17,2020 1:06 AM > To: user-zh Subject: Re: Flink yarn

Flink APP restart policy not working

2020-07-22 Thread Rainie Li
各位大佬好, 本人Flink新手上路,想咨询一下有时候Flink App 设置了restartPolicy 但是还是restart不了,这种情况怎么破? *Job’s restartPolicy:* *env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1000, org.apache.flink.api.common.time.Time.seconds(30)));* *Job Manager log:* 2020-07-15 20:26:27,831 INFO org.apache.flink.runtime.ex