chamikaramj commented on a change in pull request #12806:
URL: https://github.com/apache/beam/pull/12806#discussion_r514295070
##########
File path:
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
##########
@@ -1508,7 +1578,7 @@ public void translate(StreamingPubsubIOWrite transform,
TranslationContext conte
// Using a GlobalWindowCoder as a place holder because GlobalWindowCoder
is known coder.
stepContext.addEncodingInput(
WindowedValue.getFullCoder(VoidCoder.of(),
GlobalWindow.Coder.INSTANCE));
- stepContext.addInput(PropertyNames.PARALLEL_INPUT,
context.getInput(transform));
+ stepContext.addInput(PropertyNames.PARALLEL_INPUT, input);
Review comment:
BTW doesn't Java work (for runner v2) when we just set
PropertyNames.PUBSUB_SERIALIZED_ATTRIBUTES_FN to empty string ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
