John Lonergan created FLINK-17469:
-------------------------------------
Summary: Support override of DEFAULT_JOB_NAME with system property
for StreamExecutionEnvironment
Key: FLINK-17469
URL: https://issues.apache.org/jira/browse/FLINK-17469
Project: Flink
Issue Type: New Feature
Components: API / Core
Affects Versions: 1.10.0
Reporter: John Lonergan
We want to be able to provide the job name using a standard system property
"job.name".
We can of course write application code in each job to achieve this by passing
the system property value ourselves to the execute method.
However, there exists already default job name in
StreamExecutionEnvironment.DEFAULT_JOB_NAME.
Our proposed changed to add a method to StreamExecutionEnvironment...
{code:java}
String getDefaultJobName() {
return System.getProperty("job.name",
StreamExecutionEnvironment.DEFAULT_JOB_NAME);
}
{code}
.. and call that method rather than directly accessing
StreamExecutionEnvironment.DEFAULT_JOB_NAME
This change is backwards compatible.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
