您可以在spark-submit命令中使用以下参数。
--queue queue_name
您可以在代码中设置此属性。 spark.yarn.queue
spark.yarn.queue
希望这会有所帮助。
谢谢
尝试使用“yarn.spark.queue”而不是“queue”。
conf = pyspark.SparkConf().set("yarn,spark.queue", "your_queue_name") sc