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. Cheers, Till ​ On Fri, Dec 9, 2016 at 7:33 PM, Shannon Carey <sca...@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 >
