可以考虑使用setNumWorkers方法增加Worker数目。
可以考虑使用setSplitSize方法减少切分大小，提高作业载入数据速度。
加大Worker的CPU或内存。
设置最大迭代次数，如果有些应用结果精度要求不高，可以考虑减少迭代次数，尽快结束。

尝试Combiner，将这些Key对应点的消息进行本地聚合，以减少存储消息的内存和网络数据流量，缩短作业的执行时间。