private void callBeforeTaskComplete() {
    if (taskCounter != null) {
      // reporter metrics by flink, counter the number of tasks consumed
      taskCounter.inc();
    }
  }
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