[jira] [Created] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[Shang Yuanchun (Jira)]

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)