[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104727#comment-17104727 ]
Roey Shem Tov commented on FLINK-17469: --------------------------------------- Adding to this conversation, i am agree with the second solution [~aljoscha] offers. Flink need to support more cli application commands (such as -p), for example --appName or --name can be a good solution over here. > 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 / DataSet, API / DataStream > Affects Versions: 1.10.0 > Reporter: John Lonergan > Priority: Trivial > > We are running multiple jobs on a shared standalone HA Cluster. > We want to be able to provide the job name via the submitting shell script > using a system property; for example "job.name". > We could of course write Java application code in each job to achieve this by > passing the system property value ourselves to the execute(name) method, > however we want to do this from the env. > --- > 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("default.job.name", > StreamExecutionEnvironment.DEFAULT_JOB_NAME); > } > {code} > .. and call that method rather than directly accessing > StreamExecutionEnvironment.DEFAULT_JOB_NAME > This change is backwards compatible. > We need this method to evalulate on a job by job basis so for example the > following small amendment to the existing DEFAULT_JOB_NAME value will NOT > work because this will not allow us to vary the value job by job. > {code:java} > class StreamExecutionEnvironment { > static final String DEFAULT_JOB_NAME = > System.getProperty("default.job.name", "Flink Streaming Job")) > } > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)