Hi all,
i have declared spark context at start of my program and then i want to
change it's configurations at some later stage in my code as written below
val conf = new SparkConf().setAppName("Cassandra Demo")
var sc:SparkContext=new SparkContext(conf)
sc.getConf.set("spark.cassandra.connection.host", host)
println(sc.getConf.get("spark.cassandra.connection.host"))
in the above code following exception occur
Exception in thread "main" java.util.NoSuchElementException:
spark.cassandra.connection.host
Actually I want to set cassandra host property and i just want to set this
if there is some job related to cassandra so i declare sparkcontext earlier
and then want to set this property at some later stage.
Any suggestion?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/setting-spark-configuration-properties-problem-tp22764.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
