From 201cf508cb438490171d4cfb7a8e5b19b8cffaaf Mon Sep 17 00:00:00 2001 From: lostluck <13907733+lostluck@users.noreply.github.com> Date: Mon, 31 Jul 2023 07:58:56 -0700 Subject: [PATCH] fix typos. --- sdks/go/pkg/beam/runners/prism/internal/handlerunner.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sdks/go/pkg/beam/runners/prism/internal/handlerunner.go b/sdks/go/pkg/beam/runners/prism/internal/handlerunner.go index 914f032a17df..27303f03b705 100644 --- a/sdks/go/pkg/beam/runners/prism/internal/handlerunner.go +++ b/sdks/go/pkg/beam/runners/prism/internal/handlerunner.go @@ -91,11 +91,11 @@ func (h *runner) PrepareTransform(tid string, t *pipepb.PTransform, comps *pipep // since the input collection and output collection types match. // Get the input and output PCollections, there should only be 1 each. - if len(t.GetOutputs()) != 1 { - panic("Expected single putput PCollection in reshuffle: " + prototext.Format(t)) + if len(t.GetInputs()) != 1 { + panic("Expected single input PCollection in reshuffle: " + prototext.Format(t)) } if len(t.GetOutputs()) != 1 { - panic("Expected single putput PCollection in reshuffle: " + prototext.Format(t)) + panic("Expected single output PCollection in reshuffle: " + prototext.Format(t)) } inColID := getOnlyValue(t.GetInputs())