Hi tison,

This information is very helpful. Thank you!

Best,
Paul Lam


> 在 2018年8月30日,10:41,陈梓立 <wander4...@gmail.com> 写道:
> 
> Hi Paul,
> 
> For your information,  `yarn.taskmanager.env.JAVA_HOME` is deprecated, you 
> can set env of taskmanager using the key similar to jobmanager, that is 
> `containerized.taskmanager.env.JAVA_HOME`
> All args with prefix `containerized.taskmanager.env.` would be passed to 
> taskmanager, similar to jobmanager.
> 
> Best,
> tison.
> 
> 
> Paul Lam <paullin3...@gmail.com <mailto:paullin3...@gmail.com>> 于2018年8月30日周四 
> 上午10:35写道:
> Hi vino,
> 
> Yes, I’m trying to set Java 8 environment for Flink job, but YARN is running 
> on Java 7 which I can’t change.
> 
> I find the solution in the mail list you referred to. It turns out that I was 
> using a wrong key to set Java home for the jobmanager, and the right key 
> should be “containerized.master.env.JAVA_HOME”.
> 
> Thank you very much!
> 
> Best,
> Paul Lam
> 
>> 在 2018年8月30日,10:09,vino yang <yanghua1...@gmail.com 
>> <mailto:yanghua1...@gmail.com>> 写道:
>> 
>> Hi Paul,
>> 
>> This exception means that the jdk version of the execution code is lower 
>> than the compiled jdk version. 
>> 52 means that the JDK version that compiles it is 1.8. 
>> There is information that Flink 1.4 has removed support for Java 7, so your 
>> current best choice is to use JDK 1.8.[1]
>> 
>> [1]: 
>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-1-4-0-can-not-override-JAVA-HOME-for-single-job-deployment-on-YARN-td17265.html
>>  
>> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-1-4-0-can-not-override-JAVA-HOME-for-single-job-deployment-on-YARN-td17265.html>
>> 
>> Thanks, vino.
>> 
>> Paul Lam <paullin3...@gmail.com <mailto:paullin3...@gmail.com>> 
>> 于2018年8月30日周四 上午9:58写道:
>> Hi vino,
>> 
>> Thanks for your suggestion. I believe it’s working. But I still get this 
>> exception in jobmanager.err:
>> 
>> > java.lang.UnsupportedClassVersionError: 
>> > org/apache/flink/yarn/entrypoint/YarnSessionClusterEntrypoint : 
>> > Unsupported major.minor version 52.0
>> 
>> I tried setting Java home for the jobmanager too, but it doesn’t help.
>> 
>> Do you have any idea on this? Thanks a lot!
>> 
>> Best,
>> Paul Lam
>> 
>> 
>>> 在 2018年8月29日,16:08,vino yang <yanghua1...@gmail.com 
>>> <mailto:yanghua1...@gmail.com>> 写道:
>>> 
>>> Hi Paul,
>>> 
>>> You can try: -yD yarn.taskmanager.env.JAVA_HOME=xx in the command line.
>>> 
>>> Thanks, vino.
>>> 
>>> Paul Lam <paullin3...@gmail.com <mailto:paullin3...@gmail.com>> 
>>> 于2018年8月29日周三 下午3:27写道:
>>> Hi,
>>> 
>>> I’m trying to run Flink on a YARN cluster that’s running on JDK 7, and I 
>>> think it’s a quite common scenario, but it seems that currently there’s no 
>>> way to pass the JAVA_HOME environment variable to YARN.
>>> 
>>> Am I missing something? And should I create an issue requesting for that?
>>> 
>>> Best,
>>> Paul Lam
>> 
> 

Reply via email to