Re: Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-17 Thread 杨光
Hi Stephan I tested my case again and found the parameters "-yD containerized.taskmanager.env.JAVA_HOME=/opt/jdk1.8.0_121 -yD containerized.master.env.JAVA_HOME=/opt/jdk1.8.0_121" and "-yD yarn.taskmanager.env.JAVA_HOME=/opt/jdk1.8.0_121 -yD containerized.master.env.JAVA_HOME=/opt/jdk1.8.0_1

Re: Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-15 Thread Stephan Ewen
Could you open an issue to add the old config keys as backwards supported "deprecated keys"? That should help making the transition smoother. On Fri, Dec 15, 2017 at 9:29 AM, Fabian Hueske wrote: > Thanks for reporting back! > > 2017-12-15 4:52 GMT+01:00 杨光 : > >> Yes , i'm using Java8 , and i f

Re: Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-15 Thread Fabian Hueske
Thanks for reporting back! 2017-12-15 4:52 GMT+01:00 杨光 : > Yes , i'm using Java8 , and i found the 1.4 version provided new > parameters : "containerized.master.env.ENV_VAR1" and > "containerized.taskmanager.env". > I change my start command from "-yD yarn.taskmanager.env.JAVA_HOME" to > " -y

Re: Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-14 Thread 杨光
Yes , i'm using Java8 , and i found the 1.4 version provided new parameters : "containerized.master.env.ENV_VAR1" and "containerized.taskmanager.env". I change my start command from "-yD yarn.taskmanager.env.JAVA_HOME" to " -yD containerized.taskmanager.env.JAVA_HOME=/opt/jdk1.8.0_121 -yD contai

Re: Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-14 Thread Nico Kruber
Hi, are you running Flink in an JRE >= 8? We dropped Java 7 support for Flink 1.4. Nico On 14/12/17 12:35, 杨光 wrote: > Hi, > I am usring flink single-job mode on YARN. After i upgrade flink > verson from 1.3.2 to 1.4.0, the parameter > "yarn.taskmanager.env.JAVA_HOME" doesn’t work as before. >

Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN

2017-12-14 Thread 杨光
Hi, I am usring flink single-job mode on YARN. After i upgrade flink verson from 1.3.2 to 1.4.0, the parameter "yarn.taskmanager.env.JAVA_HOME" doesn’t work as before. I can only found error log on yarn like this: Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/flin