import java.util
val sparkProperties = new util.HashMap[String, String]
sparkProperties.put("maximizeResourceAllocation", "true")
val sparkConfiguration = new Configuration().withClassification("spark").withProperties(sparkProperties)
new RunJobFlowRequest()
.withAdditionalInfo(additionalInfoStr)
.withApplications(spark)
......
.withConfigurations(sparkConfiguration)
1条答案
按热度按时间ogq8wdun1#
下面的代码有助于在集群级别设置配置