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

• Type: Bug
• Status: Open
• Priority: P2
• Resolution: Unresolved
• Component/s: io-py-common
• Assignee: Unassigned
• Reporter: Kamil Breguła (SF)
• Created: 09/Mar/22 18:07
• Updated: 05/Jun/22 00:35

Description

SnowflakeIO for Python SDK is not working. Each launch of the pipelines ends with the following error message.
RuntimeError:

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]

 

Issue Links

• links to: GitHub Pull Request #17054