Skip to content

Commit

Permalink
Fix integration tests
Browse files Browse the repository at this point in the history
  • Loading branch information
RustedBones committed Dec 14, 2023
1 parent acfb416 commit 2e65b7e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ class SortMergeBucketParityIT extends AnyFlatSpec with Matchers {

val outputPath = new File(tempFolder, s"source$n")

sc.parallelize(data)
sc.parallelize[GenericRecord](data)
.saveAsSortedBucket(
AvroSortedBucketIO
.write(classOf[Integer], "key", schema)
Expand Down

0 comments on commit 2e65b7e

Please sign in to comment.