相关疑难解决方法(0)

Spark配置:SPARK_MEM与SPARK_WORKER_MEMORY

在spark-env.sh中,可以配置以下环境变量:

# - SPARK_WORKER_MEMORY, to set how much memory to use (e.g. 1000m, 2g)
export SPARK_WORKER_MEMORY=22g
[...]
# - SPARK_MEM, to change the amount of memory used per node (this should
#   be in the same format as the JVM's -Xmx option, e.g. 300m or 1g)
export SPARK_MEM=3g
Run Code Online (Sandbox Code Playgroud)

如果我用这个启动一个独立的集群:

$SPARK_HOME/bin/start-all.sh
Run Code Online (Sandbox Code Playgroud)

我可以在Spark Master UI网页上看到所有工作人员只有3GB内存:

-- Workers Memory Column --
22.0 GB (3.0 GB Used)
22.0 GB (3.0 GB Used)
22.0 GB (3.0 GB Used)
[...]
Run Code Online (Sandbox Code Playgroud)

但是,我在spark-env.sh中将22g指定为SPARK_WORKER_MEMORY

我有点困惑.可能我不明白"节点"和"工人"之间的区别.

有人可以解释两个内存设置之间的差异以及我可能做错了什么吗?

我正在使用spark-0.7.0.有关更多配置信息,另请参见此处.

scala mapreduce apache-spark

9
推荐指数
1
解决办法
4199
查看次数

标签 统计

apache-spark ×1

mapreduce ×1

scala ×1