[
https://issues.apache.org/jira/browse/BEAM-12438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Burke updated BEAM-12438:
--------------------------------
Fix Version/s: Not applicable
Resolution: Fixed
Status: Resolved (was: Open)
> Sharing input to both a GBK and a CoGBK causes LP error w/schemas
> -----------------------------------------------------------------
>
> Key: BEAM-12438
> URL: https://issues.apache.org/jira/browse/BEAM-12438
> Project: Beam
> Issue Type: Improvement
> Components: sdk-go
> Reporter: Robert Burke
> Assignee: Robert Burke
> Priority: P2
> Fix For: Not applicable
>
> Time Spent: 3h 10m
> Remaining Estimate: 0h
>
> Constructing a pipeline with a PCol<KV> (call it A) used as an input to a
> GBK, using that output to generate an PCol<KV> (call it B) and using both A
> and B as inputs to a CoGBK causes the DoFn after the CoGBK to fail with an
> encoding error.
> Essentially the Length Prefix coder applied to A isn't applied to the output
> of the CoGBK for the expand, causing the pipeline to fail. Only happens with
> Row encoded structs.
> This is likely due to CoGBK being a synthetic construct on top of a GBK with
> a extra Inject and Expand operations, with the Inject missing the LP coding
> that the earlier GBK received.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
