You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kevin Sijo Puthusseri (Jira)" <ji...@apache.org> on 2020/08/22 01:39:00 UTC
[jira] [Created] (BEAM-10796) Python's Test Expansion Service for
Combine transform returns pickled coder
Kevin Sijo Puthusseri created BEAM-10796:
--------------------------------------------
Summary: 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
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)