缘由:默认状况下每一个节点分配的执行内存为1Gapp
解决办法:ide
方法一:val conf = new SparkConf().setAppName("appname").set("spark.executor.memory","6g")spa
方法二:修改spark-env.sh内存
添加:export SPARK_EXECUTOR_MEMORY=8Git