有没有办法在使用命令行提交作业来测量Apache Flink中的作业执行时间?
PS.我希望flink API给我时间,而不是通过记录开始和结束时间来自己测量它
该ExecutionEnvironment.execute()
方法返回JobExecutionResult
包含作业运行时的对象.
你可以做一些像这样的事情:
// execute program
JobExecutionResult result = env.execute("My Flink Job");
System.out.println("The job took " + result.getNetRuntime(TimeUnit.SECONDS) + " to execute");