Here is a snippet of the code:   object SparkCSVParser { def main(args: Array[String]) {     val sc = new SparkContext(new SparkConf().setAppName("Spark Count"))       val restClient = Client.create()     val webResource = restClient.resource(tsd)   // JSONValue works outside of map partition, class is found   tokenized.mapPartitions(lines => { val parser = new CSVParser(',')     lines.map( line => {          import org.json.simple.JSONValue          val columns = parser.parseLine(line)          var sensorMetrics = ArrayBuffer[String]() for ((sName, sValuePos) <- nameToPos) {       val json = ("metric" -> sName) ~          ("timestamp" -> (hoursInSec * columns(otherNameToPos("HOURS")).toInt).+(today / toSeconds - dayInSec)) ~          ("value" -> columns(sValuePos)) ~          ("tags" -> Map {"engine_index" -> columns(otherNameToPos("ENGINE_INDEX"))})           sensorMetrics += pretty(json) }     JSONValue.toJSONString(sensorMetrics) // <- it does not work here. Class is nor found }) }).take(10).foreach( webResource .accept(MediaType.APPLICATION_JSON_TYPE) .`type`(MediaType.APPLICATION_FORM_URLENCODED_TYPE) .post(classOf[ClientResponse], _))   }   running on "--master local"   Here is the error: 15/01/15 21:43:35 WARN TaskSetManager: Lost task 0.0 in stage 0.0 (TID 0, localhost): java.lang.NoClassDefFoundError: org/json/simple/JSONValue     at com.decisioniq.spark.SparkTrainCSVParser$$anonfun$main$1$$anonfun$apply$1.apply(SparkTrainCSVParser.scala:136)     at com.decisioniq.spark.SparkTrainCSVParser$$anonfun$main$1$$anonfun$apply$1.apply(SparkTrainCSVParser.scala:119)     at scala.collection.Iterator$$anon$11.next(Iterator.scala:328)     at scala.collection.Iterator$$anon$10.next(Iterator.scala:312)     at scala.collection.Iterator$class.foreach(Iterator.scala:727)     How can I make it discover this class?   ... View more

So I have noticed that operations can still continue when zookeeper fails 1 node of it's 3 node quorum although I understand that it can no longer accept writes because it has no leader (is this right). I know we have to satisfy the ceil(N/2) requirement, but this is to chose leadership it says nothing about how the dependencies (HBase in particular) would be affected.   My questions is at it's core, what is the behavior of zookeeper when failure is seen from 3 nodes to 2. Does it turn into a read only coordinator, as an immediate fix can one be assigned master?   Thanks. ... View more