Murtaza H Zaveri created FLINK-19580:
----------------------------------------
Summary: Creating PackagedProgram overwrites an actual job name
with default JobName
Key: FLINK-19580
URL: https://issues.apache.org/jira/browse/FLINK-19580
Project: Flink
Issue Type: Bug
Components: Client / Job Submission
Affects Versions: 1.11.2
Reporter: Murtaza H Zaveri
Hi Team,
Flink Version : Flink 1.11.X
We are creating JobGraph through packagedProgram and trying to submit the flink
job using rest client. hence to do so we are using below API,
*_createJobGraph(packagedProgram,configuration,defaultParallelism,jobId,suppressOutput);_*
In Above method's implementation, it creates a pipeline a object and this
pipeline object calls OptimizerPlanEnvironment(which is used to extract the
Pipeline) and this instance override an actual job name with the default
jobName viz, *Flink Java Job <Date time>.*
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
