You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2020/11/04 17:11:01 UTC
[jira] [Updated] (BEAM-10796) Python's Test Expansion Service for
Combine transform returns pickled coder
[ https://issues.apache.org/jira/browse/BEAM-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot updated BEAM-10796:
---------------------------------
Labels: (was: stale-P2)
> Python's Test Expansion Service for Combine transform returns pickled coder
> ---------------------------------------------------------------------------
>
> Key: BEAM-10796
> URL: https://issues.apache.org/jira/browse/BEAM-10796
> Project: Beam
> Issue Type: Bug
> Components: sdk-go, sdk-py-core
> Reporter: Kevin Sijo Puthusseri
> Priority: P3
>
> Trying to use the combine transform of Python's test expansion service executed from the Go SDK fails during runtime. Crashes the Go SDK harness with the following error:
> unmarshalling coder VSkoscjkPN_Coder_TupleCoder_7_length_prefixed_windowednmarshalling coder VSkoscjkPN_Coder_TupleCoder_7_length_prefixed_windowed unmarshalling coder VSkoscjkPN_Coder_TupleCoder_7_length_prefixed unmarshalling coder VSkoscjkPN_Coder_FastPrimitivesCoder_1_length_prefixedcould not unmarshal length prefix coder from spec:<urn:"beam:coder:length_prefix:v1" > component_coder_ids:"VSkoscjkPN_Coder_FastPrimitivesCoder_1" , want a custom coder as a sub component but got spec:<urn:"beam:coder:pickled_python:v1" payload:"\n\310\001FastPrimitivesCoder$QlpoOTFBWSZTWSYAoHgAAC334EwIiCAAIQkAQAC/bt0CYAQOACAAahpI0Bppo0GmRtINBqJ6QZAaNDQDyjRqC0RLwD4QPbijFck85Haypu6ovZAReEmQrcsyHc7KzNN4sFkXh7FICbooOXgwoVC0QQeEDWJD5shM4hP8XckU4UJAmAKB4A==" >
--
This message was sent by Atlassian Jira
(v8.3.4#803005)