[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355606#comment-17355606 ]
Yao Zhang commented on FLINK-17775: ----------------------------------- Hi [~nikobearrr], I investigated the corresponding part in DataStream.java: {code:java} public CloseableIterator<T> executeAndCollect() throws Exception { return executeAndCollect("DataStream Collect"); } public CloseableIterator<T> executeAndCollect(String jobExecutionName) throws Exception { return executeAndCollectWithClient(jobExecutionName).iterator; } {code} It provides two implementations, with one of them can specify the job execution name. But in DataSet.java we cannot assign that name. I think we can add a collect(String jobExecutionName) method for DataSet. Could you please assign this issue to me? > Cannot set batch job name when using collect > -------------------------------------------- > > Key: FLINK-17775 > URL: https://issues.apache.org/jira/browse/FLINK-17775 > Project: Flink > Issue Type: Bug > Components: Runtime / Configuration > Affects Versions: 1.8.3, 1.9.3, 1.10.1 > Reporter: Nikola > Priority: Major > Labels: auto-deprioritized-critical, stale-major > > We have a batch job in the likes of this: > > {code:java} > ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); > DataSet<Row> dataSet = getDataSet(); > dataSet > .sortPartition(MyRow::getCount, Order.DESCENDING) > .setParallelism(1) > .flatMap(new MyFlatMap()) > .collect(); > env.execute("Job at " + Instant.now().toString()); > {code} > However, the job name in the flink UI is not "Job at <date>" but the default > as if I didn't put anything. > > Is there way to have my own flink job name? > -- This message was sent by Atlassian Jira (v8.3.4#803005)