在flink中测量作业执行时间

Question

当使用命令行将作业提交给Flink时，是否有任何方法可以测量Apache Flink中的作业执行时间？

PS。我希望flink API给我时间，而不是自己在bash中通过记录的开始和结束时间来测量时间

Answer 1

ExecutionEnvironment.execute()方法返回一个包含作业运行时的JobExecutionResult对象。

例如，你可以做这样的事情：

// execute program
JobExecutionResult result = env.execute("My Flink Job");
System.out.println("The job took " + result.getNetRuntime(TimeUnit.SECONDS) + " to execute");