您可以查看在工作区中砖集群的核心UI使用指标选项卡在集群上的细节页面。
如果司机和执行人是相同的节点类型,您还可以确定集群中的可用内核的数量以编程方式,使用Scala实用程序代码:
- 使用sc.statusTracker.getExecutorInfos.length得到节点的总数。结果包括司机节点,所以减去1。
- 使用java.lang.Runtime.getRuntime.availableProcessors每个节点的核数。
- 相乘的结果(从节点)的总数减去1可用内核的总数。
Scala示例代码:
java.lang.Runtime.getRuntime.availableProcessors* (sc.statusTracker.getExecutorInfos.length -1)