flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: How to retrieve values from yarn.taskmanager.env in a Job?
Date Mon, 12 Dec 2016 13:21:57 GMT
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 if you could open a JIRA issue.


On Fri, Dec 9, 2016 at 7:33 PM, Shannon Carey <scarey@expedia.com> wrote:

> 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 web UI in the list underneath Job Manager ->
> Configuration. However, I can't figure out how to retrieve the value from
> within a Flink job. It doesn't appear in the environment, the system
> properties, or my ParameterTool instance, and I can't figure out how I
> would get to it via the StreamExecutionEnvironment. Can anyone point me in
> the right direction?
> All I want to do is inform my Flink jobs which environment they're running
> on, so that programmers don't have to specify the environment as a job
> parameter every time they run it. I also see that there is a
> "env.java.opts" configuration… does that work in YARN apps (would my jobs
> be able to see it?)
> Thanks!
> Shannon

View raw message