首页 > 解决方案 > 如何在 Spark 中指定任务超时?

问题描述

我有一个 spark 结构化流应用程序,每批都在几秒钟内得到处理。目前,当前批次的所有任务都处于RUNNING一个多小时的状态。

如何在任务级别在 Spark 中指定超时以告诉 spark 如果任务未在定义的时间内完成,它应该重试?

标签: apache-sparkspark-structured-streaming

解决方案


推荐阅读