在 flink 中测量作业执行时间

Question

在使用命令行将作业提交到 Flink 时，有什么方法可以测量 Apache Flink 中的作业执行时间吗？

PS。我希望 flink API 给我时间，而不是通过记录开始和结束时间

在 bash 中自己测量时间

Answer 1

ExecutionEnvironment.execute() 方法 returns 包含作业运行时的 JobExecutionResult 对象。

例如，您可以这样做：

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

在 flink 中测量作业执行时间

Measure job execution time in flink

apache-flink