此错误通常解决方法是增加Spark配置中的“spark.driver.memory”和/或“spark.executor.memory”属性。以下是代码示例:
val conf = new SparkConf() .setAppName("MyApp") .setMaster("local[*]") .set("spark.driver.memory", "4g") .set("spark.executor.memory", "4g")
val sparkContext = new SparkContext(conf)