ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
    ......
    JobExecutionResult jobExecutionResult = env.execute(XXXOffline.class.getName());
    int records = jobExecutionResult.<Integer>getAccumulatorResult("counter");
    LOGGER.info("total records: {}", records);

但是，日志没有写入日志文件（ps：其他日志输出工作正常）。我认为env.execute（）阻塞了调用，当所有子任务都结束时，getaccumulatorresult（）就会执行。我不知道为什么最后一行日志输出不起作用。