khern
02/03/2022, 3:15 AMfrom pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()
df = spark.sql("SELECT * FROM ....")
But I got the error:
ERROR spark.SparkContext: Error initializing SparkContext.
org.apache.hadoop.yarn.exceptions.YarnException: Failed to submit application_1641884194120_477874 to YARN : Application rejected by queue placement policy
limdauto
02/03/2022, 9:48 AMArnaldo
02/03/2022, 2:25 PM