diff --git a/scio-parquet/src/test/scala/com/spotify/scio/parquet/avro/ParquetAvroIOTest.scala b/scio-parquet/src/test/scala/com/spotify/scio/parquet/avro/ParquetAvroIOTest.scala index 8c3a2b3da5..35ea93753d 100644 --- a/scio-parquet/src/test/scala/com/spotify/scio/parquet/avro/ParquetAvroIOTest.scala +++ b/scio-parquet/src/test/scala/com/spotify/scio/parquet/avro/ParquetAvroIOTest.scala @@ -57,7 +57,7 @@ class ParquetAvroIOFileNamePolicyTest extends FileNamePolicySpec[TestRecord] { override def failSaves = Seq( _.map(AvroUtils.newSpecificRecord).saveAsParquetAvroFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) diff --git a/scio-parquet/src/test/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIOTest.scala b/scio-parquet/src/test/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIOTest.scala index 81ba2aff9b..12a4d3c11f 100644 --- a/scio-parquet/src/test/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIOTest.scala +++ b/scio-parquet/src/test/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIOTest.scala @@ -110,7 +110,7 @@ class ParquetExampleIOFileNamePolicyTest extends FileNamePolicySpec[Example] { _.map(newExample).saveAsParquetExampleFile( "nonsense", schema, - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) diff --git a/scio-parquet/src/test/scala/com/spotify/scio/parquet/types/ParquetTypeIOTest.scala b/scio-parquet/src/test/scala/com/spotify/scio/parquet/types/ParquetTypeIOTest.scala index 6d5cc67cb4..8f2cc1bea5 100644 --- a/scio-parquet/src/test/scala/com/spotify/scio/parquet/types/ParquetTypeIOTest.scala +++ b/scio-parquet/src/test/scala/com/spotify/scio/parquet/types/ParquetTypeIOTest.scala @@ -44,7 +44,7 @@ class ParquetTypeIOFileNamePolicyTest extends FileNamePolicySpec[Wide] { override def failSaves: Seq[SCollection[Int] => ClosedTap[Wide]] = Seq( _.map(i => Wide(i, i.toString, Some(i), (1 to i).toList)).saveAsTypedParquetFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) diff --git a/scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleIOTest.scala b/scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleIOTest.scala index 77733a3ea3..2ec199cbb2 100644 --- a/scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleIOTest.scala +++ b/scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleIOTest.scala @@ -63,7 +63,7 @@ class TFExampleIOFileNamePolicyTest extends FileNamePolicySpec[Example] { override def failSaves = Seq( _.map(x => recordT(Record(x, x.toString))).saveAsTfRecordFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) diff --git a/scio-test/src/test/scala/com/spotify/scio/io/ScioIOTest.scala b/scio-test/src/test/scala/com/spotify/scio/io/ScioIOTest.scala index 3c3b337642..1bb97c39b4 100644 --- a/scio-test/src/test/scala/com/spotify/scio/io/ScioIOTest.scala +++ b/scio-test/src/test/scala/com/spotify/scio/io/ScioIOTest.scala @@ -169,7 +169,7 @@ class AvroIOFileNamePolicyTest extends FileNamePolicySpec[TestRecord] { override def failSaves: Seq[SCollection[Int] => ClosedTap[TestRecord]] = Seq( _.map(AvroUtils.newSpecificRecord).saveAsAvroFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) @@ -192,7 +192,7 @@ class TextIOFileNamePolicyTest extends FileNamePolicySpec[String] { override def failSaves: Seq[SCollection[Int] => ClosedTap[String]] = Seq( _.map(_.toString).saveAsTextFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) @@ -217,7 +217,7 @@ class ObjectIOFileNamePolicyTest extends FileNamePolicySpec[ScioIOTest.AvroRecor override def failSaves: Seq[SCollection[Int] => ClosedTap[AvroRecord]] = Seq( _.map(x => AvroRecord(x, x.toString, (1 to x).map(_.toString).toList)).saveAsObjectFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) @@ -240,7 +240,7 @@ class ProtobufIOFileNamePolicyTest extends FileNamePolicySpec[TrackPB] { override def failSaves: Seq[SCollection[Int] => ClosedTap[TrackPB]] = Seq( _.map(x => TrackPB.newBuilder().setTrackId(x.toString).build()).saveAsProtobufFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ) ) @@ -263,7 +263,7 @@ class BinaryIOFileNamePolicyTest extends FileNamePolicySpec[Nothing] { override def failSaves: Seq[SCollection[Int] => ClosedTap[Nothing]] = Seq( _.map(x => ByteBuffer.allocate(4).putInt(x).array).saveAsBinaryFile( "nonsense", - shardNameTemplate = "NNN-of-NNN", + shardNameTemplate = "SSS-of-NNN", filenamePolicySupplier = testFilenamePolicySupplier ), _.map(x => ByteBuffer.allocate(4).putInt(x).array).saveAsBinaryFile(