Fix use of wrong key in Dataflow side input

apache · Sep 18, 2018 · e5ef9b5 · e5ef9b5
1 parent 633d457
commit e5ef9b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/go/pkg/beam/runners/dataflow/dataflowlib/translate.go b/sdks/go/pkg/beam/runners/dataflow/dataflowlib/translate.go
@@ -160,7 +160,7 @@ func (x *translator) translateTransform(trunk string, id string) ([]*df.Step, er
 			}
 			steps = append(steps, side)
 
-			prop.NonParallelInputs[side.Name] = newOutputReference(side.Name, "i0")
+			prop.NonParallelInputs[key] = newOutputReference(side.Name, "i0")
 		}
 
 		in := stringx.SingleValue(rem)