激发作业创建时间

Question

如何使用任务上下文访问作业创建时间。我计划在不同的执行器中获取这段时间，并使用持久化数据对其进行设置，这些数据在以后的流程中完全有帮助。由于即使从不同的执行程序中检索到作业创建时间也是唯一的，因此它有助于跟踪一个作业中的持久化数据。有可能从中得到吗？如何访问作业数据类？TaskMetrics

Answer 1

我可以使用侦听器来执行此操作。我必须扩展类 SparkListners 并跟踪作业（作业的所有任务）何时结束，并在此基础上启动和执行操作。