I am trying to setup maxRetryDelay as below, but it looks like it is not being considered while the spark job runs. Am I missing anything?
SparkConf spark = new SparkConf()
.setAppName(“JavaExample”)
.setMaster(“local[*]”) // use the JVM as the master, great for testing
.set(“spark.couchbase.nodes”, “128.0.0.1”) // connect to couchbase on localhost
.set(“spark.couchbase.bucket.travel-sample”, “”) // open the travel-sample bucket with empty password
.set(“com.couchbase.username”, “Administrator”)
.set(“com.couchbase.password”, “password”)
.set(“spark.couchbase.maxRetries”, “10”)
.set(“spark.couchbase.maxRetryDelay”, “10000”)
.set(“spark.couchbase.minRetryDelay”, “10”)
.set(“spark.couchbase.retryStrategy”, " FailFast");