val data = spark.sparkContext.parallelize(1 to 100) val processed = data.map(x => { if (x == 50) throw new RuntimeException("Spot instance interrupted") else x }).count()
val rdd = spark.sparkContext.parallelize(1 to 10) val result = rdd.map(x => if (x == 5) throw new Exception("Instance lost") else x).collect() println(result.mkString(","))
spark.sparkContext.setCheckpointDir("/tmp/checkpoint") val data = spark.sparkContext.parallelize(1 to 200) val processed = data.map(x => { if (x == 150) throw new RuntimeException("Spot instance interrupted") else x }).checkpoint().count()
