You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kamil Breguła (SF) (Jira)" <ji...@apache.org> on 2022/03/09 18:33:00 UTC

[jira] [Assigned] (BEAM-14075) Unknown Coder URN beam:coder:pickled_python:v1 in SnowflakeIO for Python SDK

     [ https://issues.apache.org/jira/browse/BEAM-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kamil Breguła (SF) reassigned BEAM-14075:
-----------------------------------------

    Assignee: Kamil Breguła (SF)

> Unknown Coder URN beam:coder:pickled_python:v1 in SnowflakeIO for Python SDK
> ----------------------------------------------------------------------------
>
>                 Key: BEAM-14075
>                 URL: https://issues.apache.org/jira/browse/BEAM-14075
>             Project: Beam
>          Issue Type: Bug
>          Components: io-py-common
>            Reporter: Kamil Breguła (SF)
>            Assignee: Kamil Breguła (SF)
>            Priority: P2
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> SnowflakeIO for Python SDK is not working. Each launch of the pipelines ends with the following error message.
> RuntimeError:
> {code:java}
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException: org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalArgumentException: Unknown Coder URN beam:coder:pickled_python:v1. Known URNs: [beam:coder:avro:generic:v1, beam:coder:bytes:v1, beam:coder:bool:v1, beam:coder:string_utf8:v1, beam:coder:kv:v1, beam:coder:varint:v1, beam:coder:interval_window:v1, beam:coder:iterable:v1, beam:coder:timer:v1, beam:coder:length_prefix:v1, beam:coder:global_window:v1, beam:coder:windowed_value:v1, beam:coder:param_windowed_value:v1, beam:coder:double:v1, beam:coder:row:v1, beam:coder:sharded_key:v1, beam:coder:custom_window:v1]{code}
>  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)