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())