Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-10796

Python's Test Expansion Service for Combine transform returns pickled coder

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Triage Needed
    • Priority: P2
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: sdk-go, sdk-py-core
    • Labels:

      Description

      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==" > 

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              kevinsijo Kevin Sijo Puthusseri
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: