如何给不同的worker分配不同的内存
How to allot different memories to different workers
我想给spark中一个集群的不同worker分配不同的内存。
在指定 conf 时,我们可以编写 .set("spark.executor.memory", "2g") ,这将为所有相应的工作人员分配 2 GB。但是如何给不同的worker分配不同的内存。
比如我想给一个工人1g,剩下的工人2g。这可能吗?如果是,如何?
可能与 this
重复
- 似乎无法提供不同的内存限制。
- 但是文档说,如果您不提供任何约束,那么将使用机器的所有内存。因此,也许如果你有不同的机器,它可以在每台机器上使用不同数量的 RAM
.
我想给spark中一个集群的不同worker分配不同的内存。 在指定 conf 时,我们可以编写 .set("spark.executor.memory", "2g") ,这将为所有相应的工作人员分配 2 GB。但是如何给不同的worker分配不同的内存。
比如我想给一个工人1g,剩下的工人2g。这可能吗?如果是,如何?
可能与 this
重复- 似乎无法提供不同的内存限制。
- 但是文档说,如果您不提供任何约束,那么将使用机器的所有内存。因此,也许如果你有不同的机器,它可以在每台机器上使用不同数量的 RAM
.