You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Nikola (Jira)" <ji...@apache.org> on 2020/05/17 12:49:00 UTC

[jira] [Created] (FLINK-17775) Cannot set batch job name when using collect

Nikola created FLINK-17775:
------------------------------

             Summary: 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.10.1, 1.9.3, 1.8.3
            Reporter: Nikola


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)