火花创造就业时间

Question

如何使用任务上下文访问职务创建时间。我计划在不同的执行器中获得这一次，并使用持久化数据来设置它，这有助于在以后的进程中完成。由于就业创建时间是唯一的，即使从不同的执行者检索时也是如此，这有助于跟踪一个作业中的持久化数据。

能从TaskMetrics那里得到吗？

如何访问Jobdata类？

Answer 1

我可以用听众来做这个。我必须扩展类SparkListners并跟踪作业(作业的所有任务)何时结束，并根据这一点启动和执行操作。