[jira] [Created] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

[Shang Yuanchun (Jira)]

lining created FLINK-14740:
------------------------------

             Summary: Create OperatorID for OperatorMetricGroup which in batch job
                 Key: FLINK-14740
                 URL: https://issues.apache.org/jira/browse/FLINK-14740
             Project: Flink
          Issue Type: Wish
          Components: Runtime / Metrics
            Reporter: lining


Now OperatorMetricGroup which in batch job use VertexId as OperatorId. For chain operator, they'll use the same id, if two chain operators which have same name. It's no good. We could update in JobGraphGenerator.compileJobGraph
{code:java}
for (TaskInChain tic : this.chainedTasksInSequence) {
   TaskConfig t = new TaskConfig(tic.getContainingVertex().getConfiguration());
   Integer nodeId = tic.getPlanNode().getOptimizerNode().getId();
   OperatorID operatorID = this.nodeId2OperatorId.get(nodeId);
   if(operatorID == null) {
      operatorID = new OperatorID();
      this.nodeId2OperatorId.put(nodeId, operatorID);
   }
   t.addChainedTask(tic.getChainedTask(), tic.getTaskConfig(), tic.getTaskName(), operatorID.toString());
}
{code}
Then we could get id from TaskInfo.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)