diff --git a/sdks/go/test/integration/primitives/teststream.go b/sdks/go/test/integration/primitives/teststream.go index e4879f017ad5..2ecbdc183a9b 100644 --- a/sdks/go/test/integration/primitives/teststream.go +++ b/sdks/go/test/integration/primitives/teststream.go @@ -36,7 +36,7 @@ func TestStreamStrings() *beam.Pipeline { return p } -// TestStreamByteSlice tests the TestStream primitive by inserting byte slice elements +// TestStreamByteSliceSequence tests the TestStream primitive by inserting byte slice elements // then advancing the watermark to infinity and comparing the output.. func TestStreamByteSliceSequence() *beam.Pipeline { p, s := beam.NewPipelineWithRoot()