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)

Reply via email to