Как определить, восстанавливается ли приложение Spark с контрольной точки?

У меня есть некоторые глобальные переменные, которые нужно инициализировать при запуске нового потокового приложения Spark.

Это легко сделать во вновь запущенном приложении, но я не могу реализовать его, когда приложение восстанавливается с контрольной точки Spark.

Так есть ли способ определить, восстанавливается ли потоковое приложение Spark с контрольной точки?

0 ответов

Другие вопросы по тегам