Setting directory for Spark recovery

Question

Hello guys! I need help with my Spark application, especially with the recovery part. I have set the recovery mode to Zookeeper and have set the URL. Everything is fine and the connection is also happening as expected. I am stuck with the last part. I want to set the directory where the recovery state is stored. Please mention the commands to set this directory. Thanks

Answer 1

You can set the directory to store the recovery state dynamically. Here is the command you can use to do it:

val sc = new SparkContext(new SparkConf())

./bin/spark-submit <all your existing options> --spark.deploy.zookeeper.dir=<path to directory>