[
https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785
]
John Lonergan commented on FLINK-17469:
---------------------------------------
What I'm really after is to be able to provide the job name from the CLI rather
than from inside the code.
We wanted to take the job name out of the "application code" that the developer
writes and move this logic/naming to our standard control wrapper scripts so
that we can enforce some name derivation rules and impose those names from the
outside.
So, my suggestion to modify the framework by the introduction of
getDefaultJobName is really just a means to providing a hook to that end.
However, if you think about it I'm not really trying to change the default job
name to some other constant, I'm actually trying to inject the actual distinct
job name on a job by job basis.
So an explicit means to set the job name from the CLI is really what we want.
Changing fliunk-conf.yaml is really only applicable if one is really trying to
override the default name for when no name is provided - but as I mentioned
above that is not really what I am after.
As long as we provide a command line option "--jobname' that I can set when I
submit a job then probably that is good enouigh for my use case.
If in additon we remove DEFAULT_JOB_NAME from the code and move it into
flink-conf.yaml then that also seems sensible for other use cases - and I hate
constants like that.
> 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)
