fix typos.

apache · Jul 31, 2023 · 201cf50 · 201cf50
1 parent 680cf56
commit 201cf50
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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())