diff --git a/integration/src/test/scala/com/spotify/scio/smb/SortMergeBucketParityIT.scala b/integration/src/test/scala/com/spotify/scio/smb/SortMergeBucketParityIT.scala
index 8d3c1198c9..ed7373b60e 100644
--- a/integration/src/test/scala/com/spotify/scio/smb/SortMergeBucketParityIT.scala
+++ b/integration/src/test/scala/com/spotify/scio/smb/SortMergeBucketParityIT.scala
@@ -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)