Sorry, I didn't see the original message already mentioned in these
configurations. But it do works for me. I put these into flink-conf.yml,
not try the way you did.
On Mon, Apr 29, 2019 at 9:45 AM Yaoting Gong
wrote:
> Hi, @胡逸才, I've met the same problem. Add some configs as blow will help
Hi, @胡逸才, I've met the same problem. Add some configs as blow will help
you .
env.java.home: /usr/jdk1.8.0_51containerized.master.env.JAVA_HOME:
/usr/jdk1.8.0_51containerized.taskmanager.env.JAVA_HOME:
/usr/jdk1.8.0_51yarn.taskmanager.env.JAVA_HOME:
/usr/jdk1.8.0_51
On Sun, Apr 28, 2019 at 1
Thank you for your reminder, I will pay attention to this issue in the future.
I read some flink source code and saw that there are a lot of new features of
java8, such as CompletableFuture and Lambda expressions, which causes flink do
not run in jdk 1.7 environment, so you may need to upgrade y
Flink源码中用到了很多java1.8的特性,所以用jdk1.7是不行的
发自我的 iPhone
> 在 2019年4月26日,17:48,胡逸才 写道:
>
> At present, all YARN clusters adopt JAVA 7 environment.
>
> While trying to use FLINK to handle the deployment of flow processing
> business scenarios, it was found that FLINK ON YARN mode always failed to
> p
At present, all YARN clusters adopt JAVA 7 environment.
While trying to use FLINK to handle the deployment of flow processing business
scenarios, it was found that FLINK ON YARN mode always failed to perform a
session task. The application log of YARN shows Unsupported major. minor
version 52.0