我在试着给你的客户做spark的工作。我有两个节点，每个节点都有以下配置。

我得到“executorlostfailure（executor 1 lost）”。
我已经尝试了大多数的Spark调谐配置。我已经减少到一个执行失败，因为最初我有6个执行失败。
以下是我的配置（我的spark提交）：
hadoop\u user\u name=hdfs spark submit--class genkvs.createfieldmappings--master yarn client--driver memory 11g--executor memory 11g--total executor cores 16--num executors 15--conf“spark.executor.extrajavaoptions=-xx:+usecompressedoops-xx:+printgcdealts-xx:+printgtimestamps”--conf spark.akka.framesize=1000--spark.shuffle.memoryfraction=1--conf spark.rdd.compress=true--conf spark.core.connection.ack.wait.timeout=800 my data/lookup\u cache\u spark-assembly-1.0-snapshot.jar-hhdfs://hdp-node-1.zone24x7.lk：8020-800页
我的数据大小是6gb，我的工作是分组。

def process(in: RDD[(String, String, Int, String)]) = {
    in.groupBy(_._4)
}

我是新来的Spark，请帮我找出我的错误。我已经挣扎了至少一个星期了。
事先非常感谢。