在flink中测量作业执行时间

Question

有没有办法在使用命令行提交作业来测量Apache Flink中的作业执行时间？

PS.我希望flink API给我时间,而不是通过记录开始和结束时间来自己测量它

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");