import io.hydrosphere.mist.lib.MistJob

object SimpleContext extends MistJob {
  /** Contains implementation of spark job with ordinary [[org.apache.spark.SparkContext]]
    * Abstract method must be overridden
    *
    * @param parameters user parameters
    * @return result of the job
    */
  override def doStuff(parameters: Map[String, Any]): Map[String, Any] = {
    val numbers: List[Int] = parameters("digits").asInstanceOf[List[Int]]
    val rdd = context.parallelize(numbers)
    Map("result" -> rdd.map(x => x * 2).collect())
  }
}


import io.hydrosphere.mist.lib.MistJob

object SimpleContext extends MistJob {
  /** Contains implementation of spark job with ordinary [[org.apache.spark.SparkContext]]
    * Abstract method must be overridden
    *
    * @param parameters user parameters
    * @return result of the job
    */
  override def doStuff(parameters: Map[String, Any]): Map[String, Any] = {
    val numbers: List[BigInt] = parameters("digits").asInstanceOf[List[BigInt]]
    val rdd = context.parallelize(numbers)
    Map("result" -> rdd.map(x => x * 2).collect())
  }
}


--- 
+++ 
@@ -8,7 +8,7 @@
     * @return result of the job
     */
   override def doStuff(parameters: Map[String, Any]): Map[String, Any] = {
-    val numbers: List[BigInt] = parameters("digits").asInstanceOf[List[BigInt]]
+    val numbers: List[Int] = parameters("digits").asInstanceOf[List[Int]]
     val rdd = context.parallelize(numbers)
     Map("result" -> rdd.map(x => x * 2).collect())
   }
Fix parameter types in examples
