public static boolean isJobTerminated(JobClient jobClient) {
    try {
      JobStatus status = jobClient.getJobStatus().get();
      return status.isGloballyTerminalState();
    } catch (Exception e) {
      // TODO
      //  This is sort of hack.
      //  Currently different execution environment will have different behaviors
      //  when fetching a finished job status.
      //  For example, standalone session cluster will return a normal FINISHED,
      //  while mini cluster will throw IllegalStateException,
      //  and yarn per job will throw ApplicationNotFoundException.
      //  We have to assume that job has finished in this case.
      //  Change this when these behaviors are unified.
      LOG.warn(
          "Failed to get job status so we assume that the job has terminated. Some data might be lost.",
          e);
      return true;
    }
  }
get ut method name without parameters.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/TestUtil.java