Thanks Tang:
Following your prompt, I deleted the useless parameters from the command line
and added your parameters to flink-config.xml, which has been successfully
implemented on YARN in the JAVA 7 environment.
At 2019-04-28 11:54:18, "Yun Tang" wrote:
Hi Zhangjun
Thanks for your
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
Hi Zhangjun
Thanks for your reply!
However, Flink user mailing list is tracked in English and user-zh mailing list
is specific for Chinese. Reply in Chinese in flink user mailing list would be
somehow unfriendly for those non-Chinese speakers.
I think your reply could be translated as
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
>
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