public void initOperatorMetric(MetricGroup metricGroup) {
    this.operatorMetricGroup = metricGroup;
    taskCounter = this.operatorMetricGroup.addGroup("amoro").addGroup("optimizer").counter("tasks");
  }
Optimizer executor For Flink engine supports:

<ul>
  <li>Add additional content to error messages to help locate execution nodes.
  <li>Add some Flink metrics like task number executed.
</ul>
amoro-optimizer/amoro-optimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java