hoolatech comments

Repositories
Issues
Comments

Results 1 comments of


                                            hoolatech

Spark Job submitted - Waiting (TaskSchedulerImpl : Initial job not accepted)

I had the same issue. ``` val sparkConf = new SparkConf() .setAppName("Spark Pi") .setMaster("spark://10.100.103.25:7077") //.setMaster("local[*]") .set("spark.serializer", classOf[KryoSerializer].getName) .set("spark.kryo.registrator", classOf[MyRegistrator].getName) .set("spark.executor.memory", "3g"); lazy val sc = new SparkContext(sparkConf) def main(args: Array[String])...