Lines Matching refs:sparkProperties

91     message.sparkProperties = conf.getAll.toMap
104     message.sparkProperties = conf.getAll.toMap
110     message.sparkProperties = badConf.getAll.toMap
113     message.sparkProperties = badConf.getAll.toMap
116     message.sparkProperties = badConf.getAll.toMap
118     message.sparkProperties = conf.getAll.toMap
126     assert(newMessage.sparkProperties("spark.app.name") === "SparkPie")
127     assert(newMessage.sparkProperties("spark.jars") === "mayonnaise.jar,ketchup.jar")
128     assert(newMessage.sparkProperties("spark.files") === "fireball.png")
129     assert(newMessage.sparkProperties("spark.driver.memory") === s"${Utils.DEFAULT_DRIVER_MEM_MB}m")
130     assert(newMessage.sparkProperties("spark.driver.cores") === "180")
131     assert(newMessage.sparkProperties("spark.driver.extraJavaOptions") ===
133     assert(newMessage.sparkProperties("spark.driver.extraClassPath") === "food-coloring.jar")
134     assert(newMessage.sparkProperties("spark.driver.extraLibraryPath") === "pickle.jar")
135     assert(newMessage.sparkProperties("spark.driver.supervise") === "false")
136     assert(newMessage.sparkProperties("spark.executor.memory") === "256m")
137     assert(newMessage.sparkProperties("spark.cores.max") === "10000")
139     assert(newMessage.sparkProperties === message.sparkProperties)