Skip to content

Commit

Permalink
Set spark.sql.execution.topKSortFallbackThreshold to 10000
Browse files Browse the repository at this point in the history
  • Loading branch information
byyue committed Sep 8, 2021
1 parent 6509a6b commit 21de1fc
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -96,6 +96,7 @@ object SparkSQLEngine extends Logging {

def createSpark(): SparkSession = {
val sparkConf = new SparkConf()
sparkConf.setIfMissing("spark.sql.execution.topKSortFallbackThreshold", "10000")
sparkConf.setIfMissing("spark.sql.legacy.castComplexTypesToString.enabled", "true")
sparkConf.setIfMissing("spark.master", "local")
sparkConf.setIfMissing("spark.ui.port", "0")
Expand Down

0 comments on commit 21de1fc

Please sign in to comment.