Commit 01423c2

authored

Correctly set # of partitions in tests (#241)

1 parent 6401c67 commit 01423c2Copy full SHA for 01423c2

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ trait SinglePartitionSparkSession {`
`25`	`25`	`.builder()`
`26`	`26`	`.master("local[1]")`
`27`	`27`	`.appName("SinglePartitionSuiteSession")`
`28`		`- .config("spark.sql.shuffle.partitions", numPartitions)`
	`28`	`+ .config("spark.default.parallelism", numPartitions)`
`29`	`29`	`.getOrCreate()`
`30`	`30`	`}`
`31`	`31`
`@@ -38,7 +38,7 @@ trait MultiplePartitionSparkSession {`
`38`	`38`	`.master(s"local-cluster[$executorInstances,1,1024]")`
`39`	`39`	`.appName("MultiplePartitionSubquerySuite")`
`40`	`40`	`.config("spark.executor.instances", executorInstances)`
`41`		`- .config("spark.sql.shuffle.partitions", numPartitions)`
	`41`	`+ .config("spark.default.parallelism", numPartitions)`
`42`	`42`	`.config(`
`43`	`43`	`"spark.jars",`
`44`	`44`	`"target/scala-2.12/opaque_2.12-0.1.jar,target/scala-2.12/opaque_2.12-0.1-tests.jar"`

Comments

(0)