File tree Expand file tree Collapse file tree
spark/src/test/scala/org/apache/spark/sql/benchmark Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ import org.apache.spark.SparkConf
2323import org .apache .spark .sql .SparkSession
2424import org .apache .spark .sql .internal .SQLConf
2525
26- import org .apache .comet .{ CometConf , CometSparkSessionExtensions }
26+ import org .apache .comet .CometSparkSessionExtensions
2727
2828/**
2929 * Benchmark to measure performance of Comet's BroadcastHashJoin across common Spark join shapes
@@ -48,12 +48,7 @@ object CometBroadcastHashJoinBenchmark extends CometBenchmarkBase {
4848 .config(conf)
4949 .withExtensions(new CometSparkSessionExtensions )
5050 .getOrCreate()
51-
52- sparkSession.conf.set(CometConf .COMET_ENABLED .key, " false" )
53- sparkSession.conf.set(CometConf .COMET_EXEC_ENABLED .key, " false" )
54- sparkSession.conf.set(SQLConf .ANSI_ENABLED .key, " false" )
5551 sparkSession.conf.set(" spark.sql.shuffle.partitions" , " 2" )
56-
5752 sparkSession
5853 }
5954
You can’t perform that action at this time.
0 commit comments