Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-13 Thread Shannon Carey
s lying in wait for a programmer to forget where it's accessible vs. not. -Shannon From: Chesnay Schepler <ches...@apache.org<mailto:ches...@apache.org>> Date: Monday, December 12, 2016 at 7:36 AM To: <user@flink.apache.org<mailto:user@flink.apache.org>> Subject: Re: How to

Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-13 Thread Till Rohrmann
gt; to forget where it's accessible vs. not. > > -Shannon > > From: Chesnay Schepler <ches...@apache.org> > Date: Monday, December 12, 2016 at 7:36 AM > To: <user@flink.apache.org> > Subject: Re: How to retrieve values from yarn.taskmanager.env in a Job? > >

Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-12 Thread Shannon Carey
hrm...@apache.org<mailto:trohrm...@apache.org>> Date: Monday, December 12, 2016 at 7:21 AM To: <user@flink.apache.org<mailto:user@flink.apache.org>> Subject: Re: How to retrieve values from yarn.taskmanager.env in a Job? Hi Shannon, have you tried accessing the environment var

Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-12 Thread Shannon Carey
ber 12, 2016 at 7:36 AM To: <user@flink.apache.org<mailto:user@flink.apache.org>> Subject: Re: How to retrieve values from yarn.taskmanager.env in a Job? Hello, can you clarify one small thing for me: Do you want to access this parameter when you define the plan (a

Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-12 Thread Chesnay Schepler
Hello, can you clarify one small thing for me: Do you want to access this parameter when you define the plan (aka when you call methods on the StreamExecutionEnvironment or DataStream instances) or from within your functions/operators? Regards, Chesnay Schepler On 12.12.2016 14:21, Till

Re: How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-12 Thread Till Rohrmann
Hi Shannon, have you tried accessing the environment variables via System.getenv()? This should give you a map of string-string key value pairs where the key is the environment variable name. If your values are not set in the returned map, then this indicates a bug in Flink and it would be great

How to retrieve values from yarn.taskmanager.env in a Job?

2016-12-09 Thread Shannon Carey
This thread http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/passing-environment-variables-to-flink-program-td3337.html describes the impetus for the addition of yarn.taskmanager.env. I have configured a value within yarn.taskmanager.env, and I see it appearing in the Flink