Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
This forces the runner to include the wire format independently from a PCollection coder, which should be the coder of the type of the PCollection (e.g. in Java, PCollection<T> has Coder<T> instead of Coder<WindowedValue<T>>, but the runner must use Coder<WindowedValue<T>> over edges).